Class BaseTerminalOperation<Original>
- java.lang.Object
-
- org.infinispan.stream.impl.termop.BaseTerminalOperation<Original>
-
- Type Parameters:
Original
- original stream type
- Direct Known Subclasses:
AbstractForEachDoubleOperation
,AbstractForEachIntOperation
,AbstractForEachLongOperation
,AbstractForEachOperation
,SegmentRetryingOperation
,SingleRunOperation
public abstract class BaseTerminalOperation<Original> extends Object
Abstract instance that provides common code needed for all terminal operations. Note this class doesn't extend any interface due to the fact that different terminal operations have possibly different interfaces to implement however all of them require the information stored here.
-
-
Field Summary
Fields Modifier and Type Field Description protected Iterable<IntermediateOperation>
intermediateOperations
protected Supplier<Stream<Original>>
supplier
-
Constructor Summary
Constructors Modifier Constructor Description protected
BaseTerminalOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterable<IntermediateOperation>
getIntermediateOperations()
void
handleInjection(ComponentRegistry registry)
void
setSupplier(Supplier<Stream<Original>> supplier)
-
-
-
Field Detail
-
intermediateOperations
protected final Iterable<IntermediateOperation> intermediateOperations
-
-
Constructor Detail
-
BaseTerminalOperation
protected BaseTerminalOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier)
-
-
Method Detail
-
getIntermediateOperations
public Iterable<IntermediateOperation> getIntermediateOperations()
-
handleInjection
public void handleInjection(ComponentRegistry registry)
-
-