从prooph事件存储区获取当前no

Question

我试图更新事件存储的投影。下面的行将加载所有事件：

$events = $this->eventStore->load(new StreamName('mystream'));

目前，我试图只通过传递fromNumber参数来加载未处理的事件：

$events = $this->eventStore->load(new StreamName('mystream'), 10);

这将载入所有事件(如从15到40 )。但我没有办法找出哪一个是目前/最高的结果“不”。但这是必要的，我只从这个条目加载在下一次。

如果数据库被截断(使用重新启动的序列)，这不是一个真正的问题，因为我知道事件将以1开头。

Answer 1

当您使用pdo-事件存储时，加载后事件元数据中有一个键_position，因此您的读取模型可以跟踪您最后处理的位置。除此之外，如果您正在处理proophs事件商店的投影，您根本不需要处理这个问题。投影仪会在内部跟踪所有需要的流的当前事件位置，您只需要为需要做一些事情的每个事件提供回调。