StreamPosition Start

EventStoreDB V20.X
1

Hello Guys

I have the following lines. The problem is that the first event from the stream is ignored. checkpointValue can be null. I thought StreamPosition.Start would have done the job. I am using .net grpc client

 var checkpointValue = await GetCheckpoint(_streamName);

 var streamPosition = checkpointValue.HasValue ? StreamPosition.FromInt64(checkpointValue.GetValueOrDefault()) : StreamPosition.Start;
2

Maybe this will help:

3

@steven.blair

Thanks. I came across that blog post but I think it is an old one That uses a different nupkg.

I am using
EventStore.Client.Grpc.Streams

@alexey.zimarev any ideas

4

What exactly are you doing, reading or subscribing? Reads should work fine.

5

I am subscribing to a catch up subscription. So start reading I try to get the existing position. If there is no existing position then I use StreamPosition.Start;

6

I guess you aren’t subscribing to all, are you?

7

I am subscribing because the 2 event does appear in the Stream… Just the first one does not appear

8

Ok, reformulating:

Are you subscribing to $all stream or to a normal stream, or to a projection stream?

9

I am subscribing to a projection… $ce-Customers

10

If you have no checkpoint (i.e. when you are starting out) use the overload that doesn’t take a StreamPosition. e.g.,

var subscription = !checkpoint.HasValue 
  ? await client.SubscribeToStream(_streamName, EventAppeared)
  : await client.SubscribeToStream(_streamName, new StreamPosition((ulong)checkpoint.Value), EventAppeared);
1 Like
11

Reference: https://github.com/Eventuous/eventuous/blob/master/src/Eventuous.EventStoreDB.Subscriptions/StreamSubscriptionService.cs#L39

1 Like