Convert Source[ByteStream] to Java InputStream

[Michael Hamrah]

I'm working with an akka-http application that takes in a POST request and needs to convert the body to a java.io.InputStream. Specifically, I need to go from a Source[akka.util.ByteString, Any] (which is what request.entity.dataBytes returns) to a java.io.InputStream. I can't seem to find the magic to make the conversion work. Can someone point me in the right direction? Seems like I'm missing an implicit conversion or a wrapping class.

Thanks,

Mike

[Roland Kuhn]

Yes, you’re missing InputStreamSink. It is not terribly complicated to write, I think, but we have not yet gotten around to it.

Regards,

Roland

--
>>>>>>>>>> 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 akka-user+...@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Dr. Roland Kuhn
Akka Tech Lead
Typesafe – Reactive apps on the JVM.
twitter: @rolandkuhn

[Viktor Klang]

In other words: a perfect opportunity for a contribution!

--

Cheers,

√

[Michael Hamrah]

;) Thanks for pointing me in the right direction. I'll give it a shot. 

You received this message because you are subscribed to a topic in the Google Groups "Akka User List" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/akka-user/4WvOrFtewQY/unsubscribe.
To unsubscribe from this group and all its topics, send an email to akka-user+...@googlegroups.com.

[Michael Hamrah]

In researching how to do this I came across akka.stream.io.OutputStreamSink which is exactly what I need: https://github.com/akka/akka/blob/releasing-akka-stream-and-http-experimental-1.0-RC3/akka-stream/src/main/scala/akka/stream/io/OutputStreamSink.scala

The code snippet is very simple:

val outputStream: () => OutputStream = { () => {

 val pipedOutputStream = new PipedOutputStream()

 //do something with the piped output stream, like connect it to a read stream

 //return for later

 pipedOutputStream

}

//somewhere else, maybe in a route:

akkaHttpRequest.entity.getDataBytes.runWith(OutputStreamSink(outputStream), flow)