在Java 9中執行Flow API的步驟是什麼？

Flow API在Java 9中對應到Reactive Streams 規範，這是事實上的標準。它包含了一組最小的接口，捕捉了非同步發布和訂閱的核心。

以下是Flow API的關鍵介面：

1) Flow.Publisher:它為訂閱者產生要消費的項目，它只包含一個方法：subscribe(Subscriber)，其目的應該是顯而易見的。

Syntax

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

2) Flow.Subscriber: It subscribes to publishers (usually only one) to receive items (via method onNext(T)), error messages (onError(Throwable)), or a signal that no more items are to be expected (onComplete()). Before any of those things happen, the publisher calls onSubscription(Subscription) method.

Syntax

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

3)  Flow.Subscription: The connection between a single publisher and a single subscriber. The subscriber can use it to request more items (request (long)) or break the connection (cancel()).

Syntax

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

Flow API的執行步驟：

• #首先，我們需要建立一個Publisher和一個Subscriber。
• 使用Publisher::subscribe訂閱Subscriber。
• Publisher建立一個Subscription並呼叫Subscriber::onSubscription，以便Subscriber可以儲存訂閱。
• 在某個時刻，Subscriber呼叫Subscription::request來請求一定數量的項目。
• Publisher透過呼叫Subscriber::onNext將專案傳遞給Subscriber。它不會發布超過請求的項目數量。
• Publisher可能在某個時刻遇到問題並分別呼叫Subscriber::onComplete或Subscriber::onError。
• Subscriber可以每隔一段時間請求更多項目，也可以透過呼叫Subscription::cancel來斷開連線。

#

以上是在Java 9中執行Flow API的步驟是什麼？的詳細內容。更多資訊請關注PHP中文網其他相關文章！