Interface StateZipper<T,​S extends Enum>

    • Method Detail

      • register

        void register​(T identifier,
                      Stateful<S> stateful)
        Register the given stream to be zipped into the state computation.
        Parameters:
        identifier - the identifier used to uniquely identify the stream.
        stateful - the stateful compontent to be registered.
      • deregister

        void deregister​(T identifier)
        Deregisters a stream identified by the identifier from the state computation.
        Parameters:
        identifier - the identifier used to uniquely identify the stream.
      • terminate

        void terminate()
        Terminate the zipper and deregister all registered streams.