Mailbox

scalus.cardano.node.stream.internal.Mailbox
See theMailbox companion trait
object Mailbox

Attributes

Companion
trait
Graph
Supertypes
class Object
trait Matchable
class Any
Self type
Mailbox.type

Members list

Value members

Concrete methods

def delta[A](maxSize: Int = ..., onCancel: () => Unit = ...): Mailbox[A]

FIFO delta mailbox. maxSize = Int.MaxValue means unbounded; any finite value fails the subscription on overflow.

FIFO delta mailbox. maxSize = Int.MaxValue means unbounded; any finite value fails the subscription on overflow.

Attributes

def latestValue[A](onCancel: () => Unit = ...): Mailbox[A]

Size-1 latest-value mailbox.

Size-1 latest-value mailbox.

Attributes