Package org.infinispan.stream.impl.termop
-
Class Summary Class Description AbstractForEachOperation<Original,K,V,S extends BaseStream<V,S>> This is a base operation class for the use of the for each terminal operator.BaseTerminalOperation<Original> Abstract instance that provides common code needed for all terminal operations.SegmentRetryingOperation<Original,E,T,S extends BaseStream<T,S>,S2 extends S> A terminal based operation that runs the provided function to evaluate the operation.SingleRunOperation<Original,E,R,S extends BaseStream<R,S>,S2 extends S> Runs the provided function once only and returns the result.TerminalOperationExternalizer AdvancedExternalizer
that provides functionality required for marshalling all of the various terminal operations that are used by various distributed streams including the primitive forms.