Re: [akka-user] Get ActorSystem as part of a stream materialization process

Thank you Konrad, it's exactly what I needed! WBR, Alexey On Saturday, July 30, 2016 at 3:56:58 PM UTC-7, Konrad Malawski wrote: > > (feel free to copy paste the entire impl and use as-is if you want to btw) > > -- > Konrad `ktoso` Malawski > Akka @ Lightbend

Re: [akka-user] Get ActorSystem as part of a stream materialization process

(feel free to copy paste the entire impl and use as-is if you want to btw) -- Konrad `ktoso` Malawski Akka @ Lightbend On 31 July 2016 at 00:52:56, Konrad Malawski (konrad.malaw...@lightbend.com) wrote: I like the idea, this can indeed be very useful!

Re: [akka-user] Get ActorSystem as part of a stream materialization process

I like the idea, this can indeed be very useful! We'll see what the rest of the team has to say about it. I took a shot at implementing it actually, so here it is: https://github.com/akka/akka/pull/21076 No guarantees about bug-free ness, but it seems rather complete ;-) It also shows of how

Re: [akka-user] Get ActorSystem as part of a stream materialization process

I'm trying to bind stream life-cycle to an actor life-cycle (let's call it master actor). In a sense that if the stream is destroyed - the master actor receives some Termination message but stays alive, but if the actor is destroyed - the stream has to be shut down as well. When I construct part

Re: [akka-user] Get ActorSystem as part of a stream materialization process

Not using safe APIs. But instead I'd turn around the question and ask what you're trying to achieve? Perhaps there's a cleaner way than reaching out to the ActorSystem. -- Konrad `ktoso` Malawski Akka @ Lightbend On 30 July 2016 at 22:39:47, oleksiys

[akka-user] Get ActorSystem as part of a stream materialization process

Hi, is it possible to get access to the ActorSystem, that is being used to materialize the stream during materialization? Something like: Flow[String].viaMat(*ExposeActorSystemMat.instance*).mapMaterializedValue(actorSystem => doSomethingWithActorSystem(actorSystem)) Thanks. WBR, Alexey