take method

Future<List<TEvent>> take(
  1. int count
)

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));
}