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
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
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
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()