readEvents method

@override Future<Iterable<StreamEvent>> readEvents(StreamName name, StreamReadPosition start, [ int count = Max ])

Read a fixed number of events from an existing stream Parameter name identifies stream to read from. Use parameter start to define the position in the stream to start reading from. Use count to limit number of events that is read from the stream (default is Max which returns all events from start).

Implementation

@override
Future<Iterable<StreamEvent>> readEvents(
  StreamName name,
  StreamReadPosition start, [
  int count = Max,
]) async {
  try {
    final read = await client.read(
      name.value,
      position: start.asStreamPosition(),
      maxCount: count,
    );
    final events = await read.events;
    return events.map(_toStreamEvent).toList();
  } on StreamNotFoundException {
    throw $e.StreamNotFoundException(name);
  }
}