Aggregate
Types
Link copied to clipboard
object Companion
Contains the inlined version of the Aggregate.exchange, Aggregate.exchanging, Aggregate.neighboring functions.
Properties
Functions
Link copied to clipboard
Inline access to the data serialization method of an Aggregate. This method is used to avoid building serializers for in-memory-only contexts.
Link copied to clipboard
abstract fun <Initial> exchange(initial: Initial, dataSharingMethod: DataSharingMethod<Initial>, body: (Field<ID, Initial>) -> Field<ID, Initial>): Field<ID, Initial>
The exchange function manages the computation of values between neighbors in a specific context. It computes a body function starting from the initial value and the messages received from other neighbors, then sends the results from the evaluation to specific neighbors or to everyone, it is contingent upon the origin of the calculated value, whether it was received from a neighbor or if it constituted the initial value.
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
abstract fun <Scalar> neighboring(local: Scalar, dataSharingMethod: DataSharingMethod<Scalar>): Field<ID, Scalar>
Observes the value of an expression local across neighbours.
Link copied to clipboard