akka の Reactive Streams を理解しようとしています。このブログhttp://bryangilbert.com/blog/2015/02/04/akka-reactive-streams/を読んだことがありますが、それがどのように機能するかについての基本的なアイデアが得られたと思います。しかし、私が理解していないのは、この概念におけるプロセッサの目的です。それはなんのためですか？サブスクライバーが N オブジェクトを要求し、パブリッシャーが onNext() を使用してそれらを送信するだけで十分ではないでしょうか?