persist
Akka Persistence 中的方法对事件序列的预期用途是什么?我看到这里有这样的签名:
final def persist[A](events: Seq[A])(handler: (A) ⇒ Unit): Unit
但是如果我尝试像下面的例子那样调用它
def receiveCommand= {
case x ⇒
val events = Seq(Event("1"), Event("2"))
persist(events) {
e ⇒ println(e) // here it gets printed "List(Event(1),Event(2))"
}
}
我将一个事件打印为List(Event(1),Event(2))
. 也就是说,我希望按照给定的顺序分别处理每个事件。但相反,它似乎在以下persist
变体中
final def persist[A](event: A)(handler: (A) ⇒ Unit): Unit
类型参数A
被替换为Seq[Event]
而不是被替换Event
并调用序列变体。使用此方法的预期方法是什么?
谢谢。