api/dev.s7a.strata.state

Package-level declarations

Types

value class StateRevision(val value: Long) : Comparable<StateRevision>

Identifies one observation in the ordered history of a state source.

data class StateSnapshot<out T>(val revision: StateRevision, val value: T)

Carries a source observation and its publication revision.

fun interface StateSource<out T>

An externally owned source of revisioned state snapshots.

StateSubscription

class StateSubscription<out T>(val initialSnapshot: StateSnapshot<T>, closeAction: () -> Unit) : AutoCloseable

The atomic result of subscribing to a StateSource.