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

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 operation
void	setSupplier(Supplier<Stream<Original>> supplier)	Sets the local supplier for the stream.

Methods inherited from interface org.infinispan.stream.impl.SegmentAwareOperation

lostSegment

Method Details

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