GossipSourceAppendNotifier

org.sigilaris.node.gossip.GossipSourceAppendNotifier
See theGossipSourceAppendNotifier companion object

Notifies runtime-owned stream drivers that a source appended an event for a chain-topic.

Wakeups are advisory and may be coalesced by implementations; retained source data and session cursors remain the delivery source of truth. Implementations should publish only after the retained append is visible to subsequent source reads.

Attributes

Companion
object
Source
Contracts.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def sourceAppended(chainTopic: ChainTopic): F[Unit]

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

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

Attributes

Source
Contracts.scala