Was sind die Schritte zur Implementierung der Flow API in Java 9?

Die

Flow API in Java 9 entspricht der Reactive Streams -Spezifikation, die ein De-facto-Standard ist. Es enthält einen minimalen Satz von Schnittstellen, die den Kern der asynchronen Veröffentlichung und des Abonnements erfassen.

Das Folgende sind die wichtigsten Schnittstellen der Flow-API:

1) Flow.Herausgeber:Er generiert Elemente, die von Abonnenten konsumiert werden sollen, und enthält nur eine Methode: subscribe(Subscriber) , darunter Der Zweck sollte offensichtlich sein.

Syntax

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

2) Flow.Subscriber: Es abonniert Herausgeber (normalerweise nur einen), um Elemente (über die Methode onNext(T)) und Fehlermeldungen (onError(Throwable)) zu erhalten ) oder ein Signal, dass keine weiteren Elemente zu erwarten sind (onComplete() Bevor eines dieser Dinge passiert, ruft der Herausgeber onSubscription(Subscription) method.

Syntax

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

3) auf Flow.Abonnement: Die Verbindung zwischen einem einzelnen Herausgeber und einem einzelnen Abonnenten Der Abonnent kann damit weitere Artikel anfordern (request(long)) oder die Verbindung unterbrechen (cancel()). .

Syntax

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

Flow-API-Ausführungsschritte:

• Zuerst müssen wir einen Publisher und einen Subscriber erstellen.
• Verwenden Sie Publisher::subscribe, um den Abonnenten zu abonnieren.
• Publisher erstellt ein Subscription und ruft Subscriber::onSubscription auf, damit der Abonnent das Abonnement speichern kann.
• Zu einem bestimmten Zeitpunkt ruft der Abonnent Subscription::request auf, um eine bestimmte Anzahl von Artikeln anzufordern.
• Der Verlag übergibt Elemente an den Abonnenten, indem er Subscriber::onNext aufruft. Es wird nicht mehr als die angeforderte Anzahl an Artikeln veröffentlicht.
• Publisher kann irgendwann auf ein Problem stoßen und Subscriber::onComplete bzw. Subscriber::onError aufrufen.
• Abonnenten können in regelmäßigen Abständen weitere Artikel anfordern oder die Verbindung trennen, indem sie Subscription::cancel aufrufen.

Das obige ist der detaillierte Inhalt vonWas sind die Schritte zur Implementierung der Flow API in Java 9?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!