replay method

Future<void> replay(
  1. String streamId,
  2. String groupName, {
  3. int? stopAt,
  4. UserCredentials? userCredentials,
  5. EventStoreClientOperationOptions? operationOptions,
})

Replay the parked messages for given subscription.

This will push the parked messages to subscribers before any new events on the subscription.

Parameters streamId and groupName identifies the PersistentSubscription to replay events on.

Use stopAt to specify the number of parked messages to replay.

Implementation

Future<void> replay(
  String streamId,
  String groupName, {
  int? stopAt,
  UserCredentials? userCredentials,
  EventStoreClientOperationOptions? operationOptions,
}) async {
  return $runRequest<void>(() async {
    await discover();
    await replayParked(
      streamId,
      groupName,
      leader,
      settings: settings,
      userCredentials: userCredentials,
      channelCredentials: $getOrAddCredentials(leader),
    );
  });
}