subscribeToParked method

Future<EventStreamSubscription> subscribeToParked(
  1. String streamId,
  2. String groupName, {
  3. Position? position,
  4. bool resolveLinks = false,
  5. UserCredentials? userCredentials,
  6. SubscriptionResolvedEventCallback? onEventAppeared,
  7. SubscriptionDroppedCallback? onSubscriptionDropped,
  8. EventStoreClientOperationOptions? operationOptions,
})

Subscribe to parked ResolveEvents.

Parameters streamId and groupName identifies the PersistentSubscription to get parked events for.

Implementation

Future<EventStreamSubscription> subscribeToParked(
  String streamId,
  String groupName, {
  Position? position,
  bool resolveLinks = false,
  UserCredentials? userCredentials,
  SubscriptionResolvedEventCallback? onEventAppeared,
  SubscriptionDroppedCallback? onSubscriptionDropped,
  EventStoreClientOperationOptions? operationOptions,
}) async {
  final client = EventStoreStreamsClient(settings);
  return client.subscribe(
    SystemStreams.persistentParkedStreamOn(
      streamId,
      groupName,
    ),
    position: position,
    resolveLinks: resolveLinks,
    onEventAppeared: onEventAppeared,
    userCredentials: userCredentials,
    operationOptions: operationOptions,
    onSubscriptionDropped: onSubscriptionDropped,
  );
}