runUntil

fun <X> runUntil(localId: ID, condition: () -> Boolean, network: Network, compute: AggregateContext.() -> X): AggregateResult<X>

Execute the aggregate computation until the condition is true.

Parameters

condition

the condition that must be true to continue the computation.

network

the network that is used to communicate with the other nodes.

compute

the function that compute the new state of the local node.