root
API
Generated with
root/org.sigilaris/org.sigilaris.node/org.sigilaris.node.gossip/org.sigilaris.node.gossip.tx/TxGossipWakeupBus

TxGossipWakeupBus

org.sigilaris.node.gossip.tx.TxGossipWakeupBus
See theTxGossipWakeupBus companion object
final class TxGossipWakeupBus[F[_]] extends GossipSourceAppendNotifier[F]

Runtime-owned bounded, coalescing wakeup bus for outbound event streams.

Each active stream owns one queue with capacity one. Additional wakeups for a stream that is already awake are coalesced, while the retained source and session cursor state remain the delivery source of truth.

Attributes

Companion
object
Source
TxGossipWakeupBus.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def activeRegistrationCount: F[Int]

Exposes registration count for cancellation/resource tests.

Exposes registration count for cancellation/resource tests.

Attributes

Source
TxGossipWakeupBus.scala
def register(sessionId: DirectionalSessionId, subscriptions: SessionSubscription): Resource[F, TxGossipWakeupSubscription[F]]

Registers an active stream for its session subscriptions.

Registers an active stream for its session subscriptions.

Attributes

Source
TxGossipWakeupBus.scala
override def sourceAppended(chainTopic: ChainTopic): F[Unit]

Publishes that retained source data may be available for a chain-topic.

Publishes that retained source data may be available for a chain-topic.

Attributes

Definition Classes
Source
TxGossipWakeupBus.scala
def wakeSession(sessionId: DirectionalSessionId, wakeup: TxGossipWakeup): F[Unit]

Publishes a session-local wakeup.

Publishes a session-local wakeup.

Attributes

Source
TxGossipWakeupBus.scala
Generated with