Fix StreamType/EventType filtering cases (#309)

EventStore · Jun 4, 2024 · d162a4a · d162a4a
1 parent fda7238
commit d162a4a
Show file tree

Hide file tree

Showing 5 changed files with 196 additions and 159 deletions.
diff --git a/src/EventStore.Client.Streams/EventStoreClient.Append.cs b/src/EventStore.Client.Streams/EventStoreClient.Append.cs
@@ -39,8 +39,8 @@ public async Task<IWriteResult> AppendToStreamAsync(
 
 			_log.LogDebug("Append to stream - {streamName}@{expectedRevision}.", streamName, expectedRevision);
 
-			var task = userCredentials is null && await _batchAppender.IsUsable().ConfigureAwait(false)
-                ? _batchAppender.Append(streamName, expectedRevision, eventData, deadline, cancellationToken)
+			var task = userCredentials is null && await BatchAppender.IsUsable().ConfigureAwait(false)
+                ? BatchAppender.Append(streamName, expectedRevision, eventData, deadline, cancellationToken)
                 : AppendToStreamInternal(
                     await GetChannelInfo(cancellationToken).ConfigureAwait(false),
                     new AppendReq {
@@ -85,8 +85,8 @@ public async Task<IWriteResult> AppendToStreamAsync(
 			_log.LogDebug("Append to stream - {streamName}@{expectedState}.", streamName, expectedState);
 
 			var task =
-				userCredentials == null && await _batchAppender.IsUsable().ConfigureAwait(false)
-					? _batchAppender.Append(streamName, expectedState, eventData, deadline, cancellationToken)
+				userCredentials == null && await BatchAppender.IsUsable().ConfigureAwait(false)
+					? BatchAppender.Append(streamName, expectedState, eventData, deadline, cancellationToken)
 					: AppendToStreamInternal(
 						await GetChannelInfo(cancellationToken).ConfigureAwait(false),
 						new AppendReq {