subscribeToAll method

Future<PersistentSubscription> subscribeToAll(
  1. String groupName, {
  2. int bufferSize = 10,
  3. bool autoAck = true,
  4. UserCredentials? userCredentials,
  5. SubscriptionDroppedCallback? onSubscriptionDropped,
  6. EventStoreClientOperationOptions? operationOptions,
  7. PersistentSubscriptionResolvedEventCallback? onEventAppeared,
})

Subscribe to ResolvedEvents in SystemStreams.AllStream.

Parameters groupName identifies which PersistentSubscription to subscribe to.

Callback PersistentSubscriptionResolvedEventCallback is invoked and awaited when a new event is received over the subscription.

Callback SubscriptionDroppedCallback is invoked and awaited when the subscription is dropped.

Returns as EventStreamSubscription on first response from the server.

Implementation

Future<PersistentSubscription> subscribeToAll(
  String groupName, {
  int bufferSize = 10,
  bool autoAck = true,
  UserCredentials? userCredentials,
  SubscriptionDroppedCallback? onSubscriptionDropped,
  EventStoreClientOperationOptions? operationOptions,
  PersistentSubscriptionResolvedEventCallback? onEventAppeared,
}) async {
  return subscribe(
    SystemStreams.AllStream,
    groupName,
    autoAck: autoAck,
    bufferSize: bufferSize,
    onEventAppeared: onEventAppeared,
    userCredentials: userCredentials,
    operationOptions: operationOptions,
    onSubscriptionDropped: onSubscriptionDropped,
  );
}