[akka-user] Akka Persistence - callback for persistAll when all events have been saved

Hi, Is there a way to execute a handler when all events have been saved using persistAll? i.e. have (handler: Seq[A] => Unit) or even (handler: () => Unit) Cheers, Łukasz -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/a

Re: [akka-user] Akka Persistence - callback for persistAll when all events have been saved

A defer() just after the persistAll call should pretty much be what you need, unless I missed something :) On Feb 28, 2016 15:23, "Łukasz Gąsior" wrote: > Hi, > > Is there a way to execute a handler when all events have been saved using > persistAll? > i.e. have (handler: Seq[A] => Unit) or even

Re: [akka-user] Akka Persistence - callback for persistAll when all events have been saved

Thanks! I think that's exactly what I need, and now that I know about it I see a section in docs right above "Nested persist calls", which I was looking at before posting my question. Cheers W dniu niedziela, 28 lutego 2016 15:50:55 UTC+1 użytkownik Konrad Malawski napisał: > > A defer() just

[akka-user] [akka-stream] tcp retransmission?

I am trying to understand why I'm seeing TCP retransmissions on a simple program. I created a small program based on the 2.4.2 docs: object HelloWorld { def main(args: Array[String]): Unit = { implicit val system = ActorSystem("Sys") implicit val materializer = ActorMaterializer()