Snapshot

data class Snapshot(val nodes: Map<NodeId, NodeInfo>) : NodeChange(source)

All known nodes as a full replacement of any previously folded state.

Subscribers receive one as the first emission of every subscription (seeded per-subscription from the engine's current node map via onSubscription), and again live whenever a handshake commits (first connect and every reconnect). Deltas that follow apply on top in causal order; a delta already reflected in the seeded snapshot re-applies idempotently.

Constructors

Link copied to clipboard
constructor(nodes: Map<NodeId, NodeInfo>)

Properties

Link copied to clipboard
val nodes: Map<NodeId, NodeInfo>