@AllParametersAndReturnValuesAreNonnullByDefault

Package org.eclipse.ditto.services.gateway.streaming.actors

Actors for streaming of websocket messages.

Interface Summary

Interface	Description
SessionedJsonifiable	Jsonifiable with information from the streaming session.

Class Summary

Class	Description
CommandSubscriber	Actor handling Commands by forwarding it to an passed in delegateActor applying backpressure.
EventAndResponsePublisher	Actor publishing Events and CommandResponses which were sent to him applying backpressure if necessary.
StreamingActor	Parent Actor for StreamingSessionActors delegating most of the messages to a specific session.
StreamingSession	Store of the needed information about a streaming session of a single streaming type.

Enum Summary

Enum	Description
StreamingActor.Control	Control messages to send in the same actor system.