EventStoreStreamsAppendMixin 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
-
append(StreamState state, Stream<EventData> events, {UserCredentials? userCredentials, EventStoreClientOperationOptions? operationOptions})
→ Future<WriteResult>
-
Append
events
to stream given by state
.
Returns as WriteResult
when the operation has completed.
If a concurrent write has occurred, a WrongExpectedVersionResult
is returned. Otherwise, WriteSuccessResult is returned.
-
discover()
→ Future<EndPoint>
-
Discover node
EndPoint
given current
EventStoreClientSettings.nodePreference.
inherited
-
isBatchAppendSupported()
→ bool
-
Check if
EventStoreClientSetting.BatchAppend
is supported by EventStoreClientSettings.apiVersion
in current settings.
-
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
-
setStreamMetadata(StreamState state, StreamMetadata metadata, {UserCredentials? userCredentials, EventStoreClientOperationOptions? operationOptions})
→ Future<WriteResult>
-
Sets the metadata for stream given by
state
.
Returns as WriteResult
when the operation has completed.
If a concurrent write has occurred, a WrongExpectedVersionResult
is returned. Otherwise, WriteSuccessResult is returned.
-
shutdown()
→ Future<void>
-
Shutdown all channels
inherited
-
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