我正在开发一个投影库,旨在支持并行化和分发任意数据流的处理。我正在使用NEventStore作为参考用例。与NEventStore PollingClient不同,我不在整个事件存储上使用游标,而是使用每个流的游标。但是在读取流时,我一直无法找到一种方法来确定哪些事件对应于哪些流修订或检查点。有没有一种直接的方法可以获取这些信息?
ICommit 具有 StreamRevision 属性:
_eventStore.Advanced.GetFrom().First().StreamRevision