Java 9 で Flow API を実装する手順は何ですか?

Flow API は、事実上の標準である Java 9 の Reactive Streams 仕様に対応します。これには、非同期パブリッシングとサブスクリプションの核となるインターフェイスの最小限のセットが含まれています。

以下は Flow API の主要なインターフェイスです:

1) Flow.Publisher: これはサブスクライバーが消費するアイテムを生成します。メソッドは subscribe(Subscriber) という 1 つだけ含まれており、その目的は明らかです。

Syntax

<strong>void subscribe(Flow.Subscriber<? super T><!--? super T--> subscriber)</strong>

2) Flow.Subscriber: パブリッシャー (通常は 1 つだけ) をサブスクライブしてアイテムを受け取ります(メソッド onNext(T) 経由)、エラー メッセージ (onError(Throwable))、またはこれ以上アイテムが期待できないことを示す信号 (onComplete()##) #).これらのことが起こる前に、パブリッシャーは onSubscription(Subscription) method.

<strong>void onSubscribe(Flow.Subscription subscription)
void onNext(T item)
void onError(Throwable throwable)
void onComplete()</strong>

ログイン後にコピー

3) を呼び出します。 Flow.Subscription: 単一の パブリッシャー と単一の サブスクライバー の間の接続。サブスクライバーはこれを使用して、さらにアイテムをリクエストできます (request (長い)) または接続を切断します (cancel())。

<strong>void request(long n)
void cancel()</strong>

ログイン後にコピー

フロー API 実行手順:

まず、
• Publisher と Subscriber を作成する必要があります。
Subscriber にサブスクライブするには、
• Publisher::subscribe を使用します。
パブリッシャーは
• Subscription を作成し、Subscriber::onSubscription を呼び出して、サブスクライバーがサブスクリプションを保存できるようにします。
ある時点で、サブスクライバーは Subscription::request を呼び出して、特定の数のアイテムをリクエストします。
• パブリッシャは、Subscriber::onNext を呼び出してアイテムをサブスクライバに渡します。要求された数を超えるアイテムは公開されません。
• パブリッシャーはある時点で問題に遭遇し、それぞれ Subscriber::onComplete または Subscriber::onError を呼び出すことがあります。
• サブスクライバーは、間隔を置いてさらにアイテムをリクエストしたり、Subscription::cancel を呼び出して切断したりできます。

以上がJava 9 で Flow API を実装する手順は何ですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。