I'm having trouble wiring the following logical flow: akka-http route -> grab request entity's source stream -> split the source stream in two -> pass the source stream to two new http requests with the source stream in the http entity.
I can easily grab the incoming request entity's source stream. I can then create a FlowGraph with a Broadcast stage to split it. However, what I can't seem to do is wire up the rest. I need two Source[ByteString]s to build the HttpEntity to make the upstream request. Using broadcast.out(0) gives me an outlet which I can't convert to a Stream; if I create a Flow, I have a bunch of ByteStrings generating sources. I believe I need to "wrap" the entire plit incoming stream--not the specific byte string chunks-in a new http request, but not sure how. Any ideas? Thanks, Mike -- >>>>>>>>>> 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.
