EventStoreStreamsSubscribeMixin mixin
- Superclass Constraints
- Mixin Applications
-
Methods
-
$createChannel(EndPoint endPoint)
→ GrpcOrGrpcWebClientChannel
-
inherited
-
$getClient()
→ Future<StreamsClient>
-
inherited
-
$toEnumerator(ResponseStream<ReadResp> stream, StreamState expected)
→ Future<ReadEnumerator<ReadResp>>
-
inherited
-
discover()
→ Future<EndPoint>
-
Discover node
EndPoint
given current
EventStoreClientSettings.nodePreference.
inherited
-
getStreamMetadata(String streamId, {UserCredentials? userCredentials, EventStoreClientOperationOptions? operationOptions})
→ Future<StreamMetadataResult>
-
Reads the metadata for stream given by
streamId
-
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
-
shutdown()
→ Future<void>
-
Shutdown all channels
inherited
-
subscribe(String streamId, {Position? position, bool resolveLinks = false, UserCredentials? userCredentials, SubscriptionResolvedEventCallback? onEventAppeared, SubscriptionDroppedCallback? onSubscriptionDropped, EventStoreClientOperationOptions? operationOptions})
→ Future<EventStreamSubscription>
-
Subscribe to ResolvedEvents from given stream
streamId
.
-
subscribeToAll({LogPosition? position, bool resolveLinks = false, UserCredentials? userCredentials, SubscriptionFilterOptions? filterOptions, SubscriptionResolvedEventCallback? onEventAppeared, SubscriptionDroppedCallback? onSubscriptionDropped, EventStoreClientOperationOptions? operationOptions})
→ Future<EventStreamSubscription>
-
Subscribe to all ResolvedEvents.
-
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