パッケージ org.springframework.xd.rxjava

XD プロセッサーモジュール内で RxJava を使用してストリーム処理を実行するための契約

partitionExpression に基づいて Observable に処理を委譲することにより、MessageHandler のアイテムを一度に配信するように適応します。