メソッドの詳細

• process

  rx.Observable<O> process(rx.Observable<I> inputStream)

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

  パラメーター:

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

  戻り値:

  メッセージバスに送信されたメッセージの出力ストリーム