data_queue library

Classes

AllCommand<TEvent>
The command takes all events from a queue.
CloneCommand<TEvent>
The command takes an event in a queue without consuming it.
CommandBase<TEvent, TResult>
Abstract command class that receives events
CountCommand<TEvent>
The command counts all events in a queue.
DataQueue<TEvent>
The class handles event and command queues.
NextCommand<TEvent>
The command consumes a next event in a queue.
QueueWorker<TEvent>
The class handles the dataQueue with built-in commands.
SkipCommand<TEvent>
The command skips the next skip events in a queue.
TakeCommand<TEvent>
The command consumes the next take events in a queue.

Exceptions / Errors

TerminatedException<T>
The exception indicates that a future was terminated by calling DataQueue.terminate.