Companion
object Companion
Global entry points.
Functions
Link copied to clipboard
fun <ID : Any, R> aggregate(localId: ID, network: Mailbox<ID>, previousState: State = emptyMap(), pathFactory: PathFactory = DigestHashingFactory(), compute: Aggregate<ID>.() -> R): AggregateResult<ID, R>
Aggregate program entry point which computes an iteration of a device localId, over a network of devices, optionally from a previousState, running the compute aggregate program.
fun <ID : Any, R> aggregate(localId: ID, previousState: State = emptyMap(), inbound: NeighborsData<ID> = NoNeighborsData(), inMemory: Boolean = inbound is NoNeighborsData, pathFactory: PathFactory = DigestHashingFactory(), compute: Aggregate<ID>.() -> R): AggregateResult<ID, R>
Aggregate program entry point which computes an iteration of a device localId, taking as parameters the previousState, the inbound messages received from the neighbors and the compute with AggregateContext receiver that provides the aggregate constructs.