Skip to content

Commit

Permalink
Merge pull request #65 from Cratis:saved-offset-fix
Browse files Browse the repository at this point in the history
Saved offset needs to be the next event it will start from (1 indexed)
  • Loading branch information
einari authored Nov 15, 2021
2 parents 434e659 + 30b85d7 commit 84140c6
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -166,8 +166,8 @@ async Task<EventLogSequenceNumber> OnNext(IProjection projection, ReplaySubject<
content));
}

await _projectionPositions.Save(projection, @event.Id);
lastSavedPosition = @event.Id;
await _projectionPositions.Save(projection, @event.Id + 1);
lastSavedPosition = @event.Id + 1;
}

return lastSavedPosition;
Expand Down

0 comments on commit 84140c6

Please sign in to comment.