メソッドを呼び出していることに注意してください。onComplete()__コールバックが呼び出されます。そのプログラムを実行すると、次のような出力が生成されます。間で同様のロジックを構築したいが、変換も適用したいとしましょう。TransformProcessor__クラスを作成します。簡単なテストを書いてみましょう。変換はここで行われる必要があります。メソッドが呼び出されることに注意してください。処理チェーン内のすべてのパブリッシャーはこのようにしてクローズする必要があることに留意してください。使用してメッセージの需要を制御するSubscriptionの最初の要素だけを使い、ロジックを適用して処理を終了したいとしましょう。メソッドを使用できます。コンストラクタ引数として渡します。//...}必要に応じて要素を要求できます。指定された__Subscriptionから1つの要素のみを消費するテストを書きましょう。1つの要素のみを処理することを要求するので、1つの要素のみを消費します。request()__メソッドを使用することで、メッセージの消費速度を制御するためのより洗練されたバックプレッシャーメカニズムを実装できます。Streamsについて説明しました。Flow__を作成する方法を見ました。Subscription__を使用しました。これらすべての例とコードスニペットの実装はhttps://github.com/eugenp/tutorials/tree/master/core-java-9[GitHubプロジェクト]にあります。そのままインポートして実行するのは簡単です。