dsl/it.unibo.collektive/Collektive

Collektive

class Collektive<ID : Any, R>(val localId: ID, network: Network<ID>, 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

Collektive

constructor(localId: ID, network: Network<ID>, computeFunction: Aggregate<ID>.() -> R)

Types

Companion

object Companion

Global entry points.

Properties

localId

val localId: ID

state

var state: State

The State of the Collektive device.

Functions

cycle

fun cycle(): R

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

cycleWhile

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.