readEventsBackwards method

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

Read a fixed number of events from an existing stream backwards from last event. Parameter name identifies stream to read from. Use count to limit number of events that is read from the stream (default is Max which returns all events from given stream).

Implementation

@override
Future<Iterable<StreamEvent>> readEventsBackwards(
  StreamName name, [
  int count = Max,
]) async {
  try {
    final read = await client.read(
      name.value,
      forward: false,
      maxCount: count,
    );
    return read.stream.asyncMap(_toStreamEvent).toList();
  } on StreamNotFoundException {
    throw $e.StreamNotFoundException(name);
  }
}