在Akka Persistence中,persist
方法的計劃用途是什麼?我看到有這樣here簽名:如何調用Seq變種持續?
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
更換調用序列變體。什麼是使用這種方法的預期方式?
謝謝。
是否'堅持[事件](事件)'工作? – Kolmar 2015-03-24 23:27:15
@Kolmar它沒有。 – ale64bit 2015-03-25 07:54:04