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.
