java - Java / Scala - ReactiveStreams / Enumeratee 如何持续读取输入流，直到 read() 返回 -1

Question

目前我有一个 Publisher[InputStream] 我怎么知道读它有类似 Java8 Streams API 提供的东西：

def binStream(is: InputStream) = Stream.continually(is.read).takeWhile(_ != -1).map(_.toByte)

目前我使用 Scala 和 playframework 并希望通过实验性的 akka-streams / reactivestreams 库对输出进行分块，但是我不知道，因为关于这两件事的文档很少甚至没有。有什么建议么？

Answer 1

akka-streams 有InputStreamSource，它在其构造函数中采用 InputStream。

这里有很多关于 Akka Streams 的文档

如果你对 play iteratee 库感兴趣（你把play-framework标签放在你的问题中）你可以使用Enumerator.fromStream方法来制作一个 Enumerator。

这里还有一些关于 Play 的 Iteratees 的文档