scala - 如何将 Source[ByteString, Any] 转换为 InputStream

Question

akka-http 表示使用 multipart/form-data 编码作为 Source[ByteString, Any] 上传的文件。我需要使用需要 InputStream 的 Java 库对其进行解码。

如何将Source[ByteString, Any]转换为InputStream？

Answer 1

从版本 2.x 开始，您可以使用以下代码实现此目的:

import akka.stream.scaladsl.StreamConverters
...
val inputStream: InputStream = entity.dataBytes
        .runWith(
           StreamConverters.asInputStream(FiniteDuration(3, TimeUnit.SECONDS))
        )

参见:http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0.1/scala/migration-guide-1.0-2.x-scala.html

注意:在 2.0.2 版本中被破坏并在 2.4.2 中修复