メソッドの詳細

• process

  org.reactivestreams.Publisher<O> process(reactor.rx.Stream<I> inputStream)

  メッセージのストリームを処理し、出力ストリームを返します。入力ストリームと出力ストリームは、メッセージバスの受信 / 送信操作にマップされます。

  パラメーター:

  inputStream - メッセージバスからメッセージを受信する入力ストリーム

  戻り値:

  メッセージバスに送信されたメッセージの出力パブリッシャー (Stream、Promise、有効な Reactive Stream Publisher)