Я работаю над библиотекой прогнозов, предназначенной для поддержки распараллеливания и распределения обработки произвольных потоков данных. Я использую NEventStore в качестве эталонного варианта использования. В отличие от NEventStore PollingClient, я использую курсор не для всего хранилища событий, а для каждого потока. Но мне не удалось найти способ при чтении потока определить, какие события соответствуют каким ревизиям или контрольным точкам потока. Есть ли простой способ получить эту информацию?
Как получить версию потока для зафиксированных событий, прочитанную из NEventStore IEventStream?
Ответы (1)
ICommit имеет свойство StreamRevision:
_eventStore.Advanced.GetFrom().First().StreamRevision
person
hnafar
schedule
02.02.2015