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]> 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]. > 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. > -- 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.
