1

現在私は Publisher[InputStream] を持っています Java8 Streams API が提供するようなものを持っていることをどのように知ることができますか?

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

現在、私は Scala と playframework を使用しており、実験的な akka-streams / reactstreams ライブラリを介して出力をチャンクしたいと考えていますが、両方に関するドキュメントがほとんどまたはまったくないため、手がかりがありません。助言がありますか？

4

1 に答える 1

1

akka-streams には、コンストラクターで InputStream を受け取る InputStreamSourceがあります。

ここにAkka Streamsに関するかなりのドキュメントがあります

play iteratee ライブラリに興味がある場合 (play-frameworkタグを質問に入れます)、Enumerator.fromStreamメソッドを使用して Enumerator を作成できます。

Play の Iteratees hereに関するかなりのドキュメントもあります

于 2015-08-05T01:47:27.930 に答える