dsl

20.1.0

dsl/it.unibo.collektive/Collektive

Collektive

class Collektive<ID : Any, R>(val localId: ID, network: Mailbox<ID>, pathFactory: PathFactory = DigestHashingFactory(), computeFunction: Aggregate<ID>.() -> R)

Create a Collektive device with a specific localId and a network to manage incoming and outgoing messages, the computeFunction is the function to apply within the AggregateContext.

Constructors

constructor(localId: ID, network: Mailbox<ID>, pathFactory: PathFactory = DigestHashingFactory(), computeFunction: Aggregate<ID>.() -> R)

Types

object Companion

Global entry points.

Properties

val localId: ID

var state: State

The State of the Collektive device.

Functions

fun cycle(): R

Apply once the aggregate function to the parameters of the device, then returns the result of the computation.

fun cycleWhile(condition: (AggregateResult<ID, R>) -> Boolean): R

Apply the aggregate function to the parameters of the device while the condition is satisfied, then returns the result of the computation.