ZHub

abstract def awaitShutdown: UIO[Unit]

Waits for the hub to be shut down.

abstract def capacity: Int

The maximum capacity of the hub.

abstract def isShutdown: UIO[Boolean]

Checks whether the hub is shut down.

abstract def publish(a: A): ZIO[RA, EA, Boolean]

Publishes a message to the hub, returning whether the message was published to the hub.

abstract def publishAll(as: Iterable[A]): ZIO[RA, EA, Boolean]

Publishes all of the specified messages to the hub, returning whether they were published to the hub.

abstract def shutdown: UIO[Unit]

Shuts down the hub.

abstract def size: UIO[Int]

The current number of messages in the hub.

abstract def subscribe: ZManaged[Any, Nothing, ZDequeue[RB, EB, B]]

Subscribes to receive messages from the hub.

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def contramap[C](f: (C) ⇒ A): ZHub[RA, RB, EA, EB, C, B]

Transforms messages published to the hub using the specified function.

final def contramapM[RC <: RA, EC >: EA, C](f: (C) ⇒ ZIO[RC, EC, A]): ZHub[RC, RB, EC, EB, C, B]

Transforms messages published to the hub using the specified effectual function.

final def dimap[C, D](f: (C) ⇒ A, g: (B) ⇒ D): ZHub[RA, RB, EA, EB, C, D]

Transforms messages published to and taken from the hub using the specified functions.

final def dimapM[RC <: RA, RD <: RB, EC >: EA, ED >: EB, C, D](f: (C) ⇒ ZIO[RC, EC, A], g: (B) ⇒ ZIO[RD, ED, D]): ZHub[RC, RD, EC, ED, C, D]

Transforms messages published to and taken from the hub using the specified effectual functions.

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

final def filterInput[A1 <: A](f: (A1) ⇒ Boolean): ZHub[RA, RB, EA, EB, A1, B]

Filters messages published to the hub using the specified function.

final def filterInputM[RA1 <: RA, EA1 >: EA, A1 <: A](f: (A1) ⇒ ZIO[RA1, EA1, Boolean]): ZHub[RA1, RB, EA1, EB, A1, B]

Filters messages published to the hub using the specified effectual function.

final def filterOutput(f: (B) ⇒ Boolean): ZHub[RA, RB, EA, EB, A, B]

Filters messages taken from the hub using the specified function.

final def filterOutputM[RB1 <: RB, EB1 >: EB](f: (B) ⇒ ZIO[RB1, EB1, Boolean]): ZHub[RA, RB1, EA, EB1, A, B]

Filters messages taken from the hub using the specified effectual function.

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def map[C](f: (B) ⇒ C): ZHub[RA, RB, EA, EB, A, C]

Transforms messages taken from the hub using the specified function.

final def mapM[RC <: RB, EC >: EB, C](f: (B) ⇒ ZIO[RC, EC, C]): ZHub[RA, RC, EA, EC, A, C]

Transforms messages taken from the hub using the specified effectual function.

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

final def toQueue: ZEnqueue[RA, EA, A]

Views the hub as a queue that can only be written to.

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit