readFromAll method

Future<ReadEventsResult> readFromAll({ int? maxCount, bool forward = true, LogPosition? position, bool resolveLinks = true, UserCredentials? userCredentials, EventStoreClientOperationOptions? operationOptions, })

Read all ResolvedEvents in EventStore from optional position. When position is not given, all events from LogPosition.start is returned when forward is true and StreamPosition.end when forward is false. Use maxCount to limit number of events to read (default is all events from given position). Use forward to read towards the end of stream. Default is true. Use resolveLinks to resolve links as ResolvedEvent (default is true). Returns as ReadEventsResult on first response from the server.

Implementation

Future<ReadEventsResult> readFromAll({
  int? maxCount,
  bool forward = true,
  LogPosition? position,
  bool resolveLinks = true,
  UserCredentials? userCredentials,
  EventStoreClientOperationOptions? operationOptions,
}) {
  return $runRequest<ReadEventsResult>(() async {
    final request = toReadAllReq(
      position ?? (forward ? LogPosition.start : LogPosition.end),
      count: maxCount,
      forward: forward,
      resolveLinks: resolveLinks,
    );
    final client = await $getClient();
    final resultStream = client.read(
      request,
      options: $getOptions(
        userCredentials: userCredentials,
        operationOptions: operationOptions,
      ),
    );
    return _toReadResult(
      StreamState.all(position),
      resultStream,
    );
  });
}