Skip to content

Commit d162a4a

Browse files
Fix StreamType/EventType filtering cases (#309)
1 parent fda7238 commit d162a4a

File tree

5 files changed

+196
-159
lines changed

5 files changed

+196
-159
lines changed

src/EventStore.Client.Streams/EventStoreClient.Append.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -39,8 +39,8 @@ public async Task<IWriteResult> AppendToStreamAsync(
3939

4040
_log.LogDebug("Append to stream - {streamName}@{expectedRevision}.", streamName, expectedRevision);
4141

42-
var task = userCredentials is null && await _batchAppender.IsUsable().ConfigureAwait(false)
43-
? _batchAppender.Append(streamName, expectedRevision, eventData, deadline, cancellationToken)
42+
var task = userCredentials is null && await BatchAppender.IsUsable().ConfigureAwait(false)
43+
? BatchAppender.Append(streamName, expectedRevision, eventData, deadline, cancellationToken)
4444
: AppendToStreamInternal(
4545
await GetChannelInfo(cancellationToken).ConfigureAwait(false),
4646
new AppendReq {
@@ -85,8 +85,8 @@ public async Task<IWriteResult> AppendToStreamAsync(
8585
_log.LogDebug("Append to stream - {streamName}@{expectedState}.", streamName, expectedState);
8686

8787
var task =
88-
userCredentials == null && await _batchAppender.IsUsable().ConfigureAwait(false)
89-
? _batchAppender.Append(streamName, expectedState, eventData, deadline, cancellationToken)
88+
userCredentials == null && await BatchAppender.IsUsable().ConfigureAwait(false)
89+
? BatchAppender.Append(streamName, expectedState, eventData, deadline, cancellationToken)
9090
: AppendToStreamInternal(
9191
await GetChannelInfo(cancellationToken).ConfigureAwait(false),
9292
new AppendReq {

0 commit comments

Comments
 (0)