Hi Martynas, I am using mapAsync with a simple method which returns a Future. The actor solution just made it unnecessarily complex. Probably custom stages would be good as well but it seemed a bit complicated for my scenario.
Thanks your comment, Krisztian On Friday, July 3, 2015 at 7:47:06 AM UTC+1, Martynas Mickevičius wrote: > > Hi Krisztian, > > is there any particular reason you want to use an actor for custom > transformations? From the description it looks like a custom stage > <http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC4/scala/stream-customize.html> > > would fit here better. > > On Tue, Jun 30, 2015 at 2:31 AM, Krisztian Lachata <[email protected] > <javascript:>> wrote: > >> Hi, >> >> I would like to have an actor in my FlowGraph which could consume data >> from a source, modify the data and after that it behave as a source and the >> push back works properly. >> Something like this: >> in ~> actor ~> out >> It there a possible way of doing this. I know that it can be a >> ActorPublisher or a ActorSubscriber like this: >> actor ~> out >> or >> in ~> actor >> but I need my actor in the middle of the flow. I know that an actor can >> be bot technically but how I have to create this actor and how I should use >> in the FlowGraph? >> >> Or Should I use mapAsync with my actor like this: >> in.mapAsync[Car](1)(x => (carAssembler ? x).mapTo[Car] ) ~> out >> but in this case I have to have a timeout defined but if it happens the >> entire flow stops after a while. >> >> I know I could do something like this: >> publisher.subscribe(procSubscriber) >> procPublisher.subscribe(subscriber) >> but in this case I cannot use the FlowGraph which is really descriptive. >> >> I hope it is clear what I would like to achieve. >> Thanks the help in advance, >> Krisztian >> >> >> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>>>> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user >> --- >> You received this message because you are subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to [email protected] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Martynas Mickevičius > Typesafe <http://typesafe.com/> – Reactive > <http://www.reactivemanifesto.org/> Apps on the JVM > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
