Skip to content

Commit 64d583d

Browse files
committed
[DEVEX-222] Added TryDeserialize method to ResolvedEvent
Currently it's implemented in a dummy way
1 parent f16ea09 commit 64d583d

File tree

2 files changed

+11
-3
lines changed

2 files changed

+11
-3
lines changed

src/Kurrent.Client/Core/ResolvedEvent.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,5 +56,10 @@ public ResolvedEvent(EventRecord @event, EventRecord? link, ulong? commitPositio
5656
? new Position(commitPosition.Value, (link ?? @event).Position.PreparePosition)
5757
: new Position?();
5858
}
59+
60+
public bool TryDeserialize(out object o) {
61+
o = true;
62+
return true;
63+
}
5964
}
6065
}

test/Kurrent.Client.Tests/Streams/Serialization/SerializationTests.cs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,13 @@ public async Task appends_and_reads_with_default_serialization() {
2121

2222
Assert.Equal(new(0), writeResult.NextExpectedStreamRevision);
2323

24-
var count = await Fixture.Streams.ReadStreamAsync(Direction.Forwards, stream, StreamPosition.Start, 2)
25-
.CountAsync();
24+
var resolvedEvents = await Fixture.Streams.ReadStreamAsync(Direction.Forwards, stream, StreamPosition.Start, 2).ToListAsync();
25+
Assert.Single(resolvedEvents);
2626

27-
Assert.Equal(1, count);
27+
var resolvedEvent = resolvedEvents.Single();
28+
29+
Assert.True(resolvedEvent.TryDeserialize(out var message));
30+
Assert.NotNull(message);
2831
}
2932

3033
private IEnumerable<UserRegistered> GenerateEvents(int count = 1) =>

0 commit comments

Comments
 (0)