Companion
object Companion
Functions
Link copied to clipboard
fun <S> deferred(ref: AggregateRef, version: Int, commandId: String, requestId: String, commandType: String, commitTime: Long, events: List<Any>, scope: Scope = Scope.NONE, causation: Causation? = null, headers: Map<String, String> = emptyMap(), operator: Operator? = null, decode: () -> S): StateEvent<S>
A committed stream whose state decode gives on its first read, once: a handler that never reads StateEvent.state costs no decoding, and one that does gets its own copy, as from invoke. A failure of decode is thrown by that read. The runtime builds them.
Link copied to clipboard
operator fun <S> invoke(ref: AggregateRef, version: Int, commandId: String, requestId: String, commandType: String, commitTime: Long, events: List<Any>, state: S, scope: Scope = Scope.NONE, causation: Causation? = null, headers: Map<String, String> = emptyMap(), operator: Operator? = null): StateEvent<S>
A committed stream; the runtime and the test DSL build them.