test-dsl/me.ahoo.wow.test/GivenAggregate

GivenAggregate

An aggregate a processor reads, as ProcessorSpec.givenAggregate gave it: its model replays its history, one commit per event, to the state and version it is at. ProcessorSpec.whenEvent hands over its next commit, and the aggregate is then at it: the next one comes after it, and ProcessorSpec.whenRedelivered and ProcessorSpec.whenDeliveredLate hand it again. A fork of the specification advances a copy of its own, which ProcessorSpec.whenEvent still finds by the aggregate's ref.

A sourcing function that reads the commit of its event reads the commit as stateEvent gives it: committed at DEFAULT_START, of the command command-<version>, in the name of the operator ProcessorSpec.whenEvent names (none in the history).

Constructors

GivenAggregate

@InternalWowApi

constructor(model: AggregateModel<S>, ref: AggregateRef, history: List<Any>, scope: Scope)

The aggregate ref of model at the state and version its history leaves it in, one commit per event.

Properties

model

val model: AggregateModel<S>

The model that evolves the aggregate's state.

ref

val ref: AggregateRef

The aggregate.

scope

val scope: Scope

The scope its commits leave it in.

state

val state: S

The state it is in, replayed anew on each read, as states are mutable.

version

var version: Int

The version it is at: one commit per event of its history, then one per commit handed over, by the specification that gave it (a fork advances a copy of its own).