Как получить версию потока для зафиксированных событий, прочитанную из NEventStore IEventStream?

Я работаю над библиотекой прогнозов, предназначенной для поддержки распараллеливания и распределения обработки произвольных потоков данных. Я использую NEventStore в качестве эталонного варианта использования. В отличие от NEventStore PollingClient, я использую курсор не для всего хранилища событий, а для каждого потока. Но мне не удалось найти способ при чтении потока определить, какие события соответствуют каким ревизиям или контрольным точкам потока. Есть ли простой способ получить эту информацию?


person jonsequitur    schedule 08.01.2015    source источник


Ответы (1)


ICommit имеет свойство StreamRevision:

_eventStore.Advanced.GetFrom().First().StreamRevision
person hnafar    schedule 02.02.2015