Package com.couchbase.client.core.state
Interface StateZipper<T,S extends Enum>
-
- All Superinterfaces:
Stateful<S>
- All Known Implementing Classes:
AbstractStateZipper
,EndpointStateZipper
,ServiceStateZipper
public interface StateZipper<T,S extends Enum> extends Stateful<S>
Describes a genericStateZipper
. See the actual implementation for theAbstractStateZipper
for more details and usage information.- Since:
- 1.1.0
- Author:
- Michael Nitschinger
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
deregister(T identifier)
Deregisters a stream identified by the identifier from the state computation.void
register(T identifier, Stateful<S> stateful)
Register the given stream to be zipped into the state computation.void
terminate()
Terminate the zipper and deregister all registered streams.-
Methods inherited from interface com.couchbase.client.core.state.Stateful
hasSubscribers, isState, state, states
-
-
-
-
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.
-
-