Package-level declarations
Types
Link copied to clipboard
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.