Asynchronous pull-based class for accessing data

DataQueue

This class is the main for building data access functionality. It manages eventsQueue (added data) and commandsQueue (added commands). You can add data with add and addAll methods. Data access is available with commands passed to the execute method.

Basic usage:

final dataQueue = DataQueue<String>();
dataQueue.add('test'); // In the dataQueue now one event - 'test'.
final next = await dataQueue.execute(NextCommand()); // result = test

QueueWorker

The QueueWorker class provides commands and a more simple way to data manipulating than DataQueue. Basic usage:

final worker = QueueWorker(DataQueue<String>());
worker.add('test'); // In the eventQueue now one event - 'test'.
worker.addAll([
'test2',
'test3'
]); // In the eventQueue now three events - 'test', 'test2', 'test3'.
final next = await worker.next; // result = test
final take = await worker.take(2); // take = 'test2', 'test3'
final count = await worker.enumerate; // count = 0, the eventQueue is empty.

Commands

All commands are based on the CommandBase interface. You can create your commands. Extend this class, and write the handle method.

Available commands:

• NextCommand - The command consumes a next event in a queue.
• TakeCommand - The command consumes the next take events in a queue.
• SkipCommand - The command skips the next skip events in a queue.
• CountCommand - The command counts all events in a queue.
• CloneCommand - The command takes an event in a queue without consuming it.
• AllCommand - The command takes all events from a queue.

Termination

You can terminate the execution of commands by the terminate method call. All commands in the queue will be complete with TerminatedException. The TerminatedException contains a command and optional command data.