プロセッサー (RxJava のサブジェクト) は、パブリッシャーとサブスクライバーの両方として機能するため、パブリッシャーにサブスクライブでき、さらにサブスクライブして、最上位のサブスクライバーから取得した値を渡すことができます。
Publisher
|
\/
Processor
|
\/
Subscriber
FluxProcessor.wrap()はこのスキーマにどのように適合しますか? たとえば、 a から値を取得し、サブスクライブして値を取得できるFluxProcessorwithを作成したいと思います。FluxProcessor.wrapFlux.range()