Interface TerminalOperation<Original,​R>

  • Type Parameters:
    R - the returing result
    All Superinterfaces:

    public interface TerminalOperation<Original,​R>
    extends SegmentAwareOperation
    Interface describing an operation that is a terminal one that doesn't track keys.
    • Method Detail

      • performOperation

        R performOperation()
        Actually runs the terminal operation returning the result from the operation
        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
        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.
        registry - component registry to use