take method
Returns a list with the next count
events from the dataQueue
The count
must be non-negative.
Implementation
Future<List<TEvent>> take(int count) {
RangeError.checkNotNegative(count, 'count');
return dataQueue.execute<List<TEvent>>(TakeCommand(count));
}