Package-level declarations
Types
Functions
Link copied to clipboard
fun <X> runUntil(localId: ID, condition: () -> Boolean, network: Network, compute: AggregateContext.() -> X): AggregateResult<X>
Execute the aggregate computation until the condition is true.
Link copied to clipboard
fun <X> singleCycle(localId: ID, messages: Collection<InboundMessage>, state: Set<State<*>>, compute: AggregateContext.() -> X): AggregateResult<X>
Execute a single cycle of the aggregate computation.