Hi, I am trying to figure out how to handle a situation where in one of your stage you need to make a call that return an InputStream, where i would deal with that stream as a Source of the stage that comes further down.
e.g. Source.map(e => Calls that return an InputStream ).via(processingFlow).runwith(sink.ignore) I would like that the element going to Processing flow as those coming from the InputStream. This is basically a situation where i am tailing a file, reading each line, the line give me the information about a call i need to make against a CLI api, when making that call i get the Stdout as an InputStream from which to read the result. Result are going to be huge most of the time, so i can just collect the all thing in memory. M -- >>>>>>>>>> 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.
