subscribeToAll method
Future<PersistentSubscription>
subscribeToAll(
- String groupName, {
- int bufferSize = 10,
- bool autoAck = true,
- UserCredentials? userCredentials,
- SubscriptionDroppedCallback? onSubscriptionDropped,
- EventStoreClientOperationOptions? operationOptions,
- 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,
);
}