Interface KeyTrackingTerminalOperation<Original,​K,​R>

    • Method Detail

      • setSupplier

        void setSupplier​(Supplier<Stream<Original>> supplier)
        This method is to be invoked only locally after a key tracking operation has been serialized to a new node
        Parameters:
        supplier - the supplier to use
      • handleInjection

        void handleInjection​(ComponentRegistry registry)
        Handles injection of components for various intermediate and this operation.
        Parameters:
        registry - component registry to use