Skip to content

Commit 82962d1

Browse files
committed
fixup some None -> NoStream leftovers.
1 parent 676cc36 commit 82962d1

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

samples/server-side-filtering/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838

3939
await client.AppendToStreamAsync(
4040
Guid.NewGuid().ToString("N"),
41-
StreamState.Any,
41+
StreamState.NoStream,
4242
new List<EventData> { eventData }
4343
);
4444
}

src/KurrentDB.Client/Streams/Streams/BatchAppendResp.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ private static WrongExpectedVersionResult FromWrongExpectedVersion(StreamIdentif
4040
WrongExpectedVersion wrongExpectedVersion) => new(streamIdentifier!,
4141
wrongExpectedVersion.ExpectedStreamPositionOptionCase switch {
4242
ExpectedStreamPosition => wrongExpectedVersion.ExpectedStreamPosition,
43-
_ => StreamState.Any,
43+
_ => StreamState.NoStream,
4444
}, wrongExpectedVersion.CurrentStreamRevisionOptionCase switch {
4545
CurrentStreamRevision => wrongExpectedVersion.CurrentStreamRevision,
4646
_ => StreamState.NoStream,

test/KurrentDB.Client.Tests/Streams/Read/ReadStreamBackwardTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ public async Task populates_log_position_of_event() {
190190
public async Task with_timeout_fails_when_operation_expired() {
191191
var stream = Fixture.GetStreamName();
192192

193-
await Fixture.Streams.AppendToStreamAsync(stream, StreamState.Any, Fixture.CreateTestEvents());
193+
await Fixture.Streams.AppendToStreamAsync(stream, StreamState.NoStream, Fixture.CreateTestEvents());
194194

195195
var rpcException = await Assert.ThrowsAsync<RpcException>(
196196
() => Fixture.Streams

0 commit comments

Comments
 (0)