Interface AggregateOperation1<T,​A,​R>

Type Parameters:
T - the type of the stream item
A - the type of the accumulator
R - the type of the aggregation result
All Superinterfaces:
AggregateOperation<A,​R>, Serializable

public interface AggregateOperation1<T,​A,​R>
extends AggregateOperation<A,​R>
Specialization of AggregateOperation (refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over. AggregateOperations contains factories for the built-in implementations and you can create your own using the aggregate operation builder.

All the functions must be stateless and cooperative.