In short I want to execute Akka graph from my API with out materializing every time.
What’s your reason for this? Just so we’re on the same page and not imagining reasons for doing this :) Problem that I am facing: How to pass request object to source node of graph. That’s as simple as using a Source that allows inserting elements from outside the stream, like Source.queue or Source.actorRef Read the docs about those. How to get corresponding response from sink node. Why “corresponding”? That sounds like you’re not stream processing really but request response thingy. You can pass around the “which request this originated from" to correlate once the sink gets it. — Konrad -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
