akkaストリームは、カバーの下にあるモデルを使用していますか？

Question

akkaストリームはどのようにカバーの下で動作しますか？

これは基本的には（http://www.michaelpollmeier.com/akka-work-pulling-pattern）を引っ張っている作業ですが、作業を引き込むメカニズムには複数のステップがありますか？

誰かが私にソースコードを教えてもらえますか？私はそれがどういう仕組みをしているのか、あまりに複雑すぎるのでしょうか？ :)

Answer 1

Akka Streams implements Reactive Streamsアイデアはストリームに「バックプレッシャー」があるため、消費者はプロデューサーにその需要を伝えることができます。

消費者がプロデューサよりも遅い場合は、「プル」します。

プロデューサが消費者よりも遅い場合、それは「プッシュ」です。

詳細については、http://www.slideshare.net/rolandkuhn/reactive-streamsを参照してください。