EventStorePersistentSubscriptionsRead mixin

Superclass Constraints
Mixin Applications

Properties

api → Versions
Get api versions. If verify is not invoked, Versions.server is null.
no setterinherited
hashCode → int
The hash code for this object.
no setterinherited
isGrpcWeb → bool
True if this client is using grpc-web protocol
finalinherited
leader → EndPoint
Get EndPoint for last known leader node. If connecting to a single node, this returns EventStoreClientSettings.singleNode.
no setterinherited
options → CallOptions?
GRPC CallOptions instance
finalinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
settings → EventStoreClientSettings
Connection name supplied as metadata to server
finalinherited
supportsClientStreamingRpc → bool
Check if grpc protocol supports client streaming See https://github.com/grpc/grpc-web/blob/master/doc/interop-test-descriptions.md
no setterinherited

Methods

$createChannel(EndPoint endPoint) → GrpcOrGrpcWebClientChannel
inherited
$getClient() → Future<PersistentSubscriptionsClient>
inherited
discover() → Future<EndPoint>
Discover node EndPoint given current EventStoreClientSettings.nodePreference.
inherited
isAllStreamSupported() → bool
Check if persistent subscription on SystemStreams.AllStream is supported by EventStoreClientSettings.apiVersion in current settings.
inherited
isFeatureSupported(ApiFeature feature) → bool
Check if given feature is supported by api.
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
readParked(String streamId, String groupName, {int? maxCount, bool forward = true, bool resolveLinks = true, StreamPosition? position, UserCredentials? userCredentials, EventStoreClientOperationOptions? operationOptions}) → Future<ReadEventsResult>
Get parked ResolveEvents.
readParkedFromAll(String groupName, {int? maxCount, bool forward = true, bool resolveLinks = true, StreamPosition? position, UserCredentials? userCredentials, EventStoreClientOperationOptions? operationOptions}) → Future<ReadEventsResult>
Get parked ResolveEvents from SystemStreams.AllStream
shutdown() → Future<void>
Shutdown all channels
inherited
subscribe(String streamId, String groupName, {int bufferSize = 10, bool autoAck = true, UserCredentials? userCredentials, SubscriptionDroppedCallback? onSubscriptionDropped, EventStoreClientOperationOptions? operationOptions, PersistentSubscriptionResolvedEventCallback? onEventAppeared}) → Future<PersistentSubscription>
Subscribes to ResolvedEvents from a persistent subscription.
subscribeToAll(String groupName, {int bufferSize = 10, bool autoAck = true, UserCredentials? userCredentials, SubscriptionDroppedCallback? onSubscriptionDropped, EventStoreClientOperationOptions? operationOptions, PersistentSubscriptionResolvedEventCallback? onEventAppeared}) → Future<PersistentSubscription>
Subscribe to ResolvedEvents in SystemStreams.AllStream.
subscribeToParked(String streamId, String groupName, {Position? position, bool resolveLinks = false, UserCredentials? userCredentials, SubscriptionResolvedEventCallback? onEventAppeared, SubscriptionDroppedCallback? onSubscriptionDropped, EventStoreClientOperationOptions? operationOptions}) → Future<EventStreamSubscription>
Subscribe to parked ResolveEvents.
subscribeToParkedFromAll(String groupName, {Position? position, bool resolveLinks = false, UserCredentials? userCredentials, SubscriptionResolvedEventCallback? onEventAppeared, SubscriptionDroppedCallback? onSubscriptionDropped, EventStoreClientOperationOptions? operationOptions}) → Future<EventStreamSubscription>
Subscribe to parked ResolveEvents from SystemStreams.AllStream
toString() → String
A string representation of this object.
inherited
verify() → Future<void>
Verify that EventStoreClientSettings.apiVersion is compatible with server version. Throws a UnsupportedApiVersionException if MemberInfo.apiVersion is incompatible with requested EventStoreClientSettings.apiVersion.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited