Package org.eclipse.ditto.services.utils.akka.streaming

Interface Summary

Interface	Description
TimestampPersistence	Defines operations for managing metadata of streams.

Class Summary

Class	Description
AbstractStreamingActor<C,E>	Abstract actor that responds to each command by streaming elements from a source to the sender of the command.
StreamAck	Ack message that is used for acking elements while streaming.
StreamConstants	Constants used for streaming utils.
StreamTrigger	Contains timestamps required for triggering a stream.

Enum Summary

Enum	Description
StreamAck.Status	Status of ACKs.