Streamsに注目します。クラスを使用することができます。ノンブロッキングバックプレッシャを使用した非同期ストリーム処理の標準です。定義されており、さまざまな実装があります。構築するために、3つの主要な抽象化を使い、それらを非同期処理ロジックに組み立てることができます。Publisherインスタンスによってそれに発行されたイベントを処理する必要があります**。購読する必要があります。Flow__処理の終わりです。考えることができます。__onComplete()があります。インタフェースを実装する必要があります。Publisher__として機能しますさらなる処理のために。消費メッセージがあります。クラスを作成しましょう。インターフェースを実装する必要があります。次に、必要なメソッドをオーバーライドします。メソッドが呼び出されます。インスタンスが引数として渡されます。__Publisherの間のメッセージの流れを制御するために使用されるクラスです。インターフェースから実装する必要があります。ここでの主なメソッドはonNext()です。新しいメッセージを発行するたびに呼び出されます。多くのメッセージを消費する準備ができていることを通知する必要があります。実装する必要があります。これは、処理で何らかの例外がスローされるときにはいつでも呼び出されます。__Flowのテストを書きましょう。