THub

zio.stm.THub
See theTHub companion class
object THub

Attributes

Companion
class
Source
THub.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type
THub.type

Members list

Value members

Concrete methods

def bounded[A](requestedCapacity: => Int): USTM[THub[A]]

Creates a bounded hub with the back pressure strategy. The hub will retain messages until they have been taken by all subscribers, applying back pressure to publishers if the hub is at capacity.

Creates a bounded hub with the back pressure strategy. The hub will retain messages until they have been taken by all subscribers, applying back pressure to publishers if the hub is at capacity.

Attributes

Source
THub.scala
def dropping[A](requestedCapacity: => Int): USTM[THub[A]]

Creates a bounded hub with the dropping strategy. The hub will drop new messages if the hub is at capacity.

Creates a bounded hub with the dropping strategy. The hub will drop new messages if the hub is at capacity.

Attributes

Source
THub.scala
def sliding[A](requestedCapacity: => Int): USTM[THub[A]]

Creates a bounded hub with the sliding strategy. The hub will add new messages and drop old messages if the hub is at capacity.

Creates a bounded hub with the sliding strategy. The hub will add new messages and drop old messages if the hub is at capacity.

For best performance use capacities that are powers of two.

Attributes

Source
THub.scala
def unbounded[A]: USTM[THub[A]]

Creates an unbounded hub.

Creates an unbounded hub.

Attributes

Source
THub.scala