Package org.infinispan.stream.impl
Interface TerminalOperation<Original,R>
-
- Type Parameters:
R
- the returing result
- All Superinterfaces:
SegmentAwareOperation
public interface TerminalOperation<Original,R> extends SegmentAwareOperation
Interface describing an operation that is a terminal one that doesn't track keys.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
handleInjection(ComponentRegistry registry)
Handles injection of components for various intermediate and this operation.R
performOperation()
Actually runs the terminal operation returning the result from the operationvoid
setSupplier(Supplier<Stream<Original>> supplier)
Sets the local supplier for the stream.-
Methods inherited from interface org.infinispan.stream.impl.SegmentAwareOperation
lostSegment
-
-
-
-
Method Detail
-
performOperation
R performOperation()
Actually runs the terminal operation returning the result from the operation- Returns:
- the value retrieved for the operation
-
setSupplier
void setSupplier(Supplier<Stream<Original>> supplier)
Sets the local supplier for the stream. This is to be invoked on a remote node after the object is unmarshalled to set the supplier to use- Parameters:
supplier
- the supplier that will return the stream that the operations are performed on
-
handleInjection
void handleInjection(ComponentRegistry registry)
Handles injection of components for various intermediate and this operation.- Parameters:
registry
- component registry to use
-
-