Quelles sont les étapes pour implémenter l'API Flow dans Java 9 ?

Flow API correspond à la spécification Reactive Streams de Java 9, qui est un standard de facto. Il contient un ensemble minimal d'interfaces qui capturent le cœur de la publication et de l'abonnement asynchrones.

Voici les interfaces clés de Flow API :

1) Flow.Publisher :Il génère des éléments à consommer par les abonnés et ne contient qu'une seule méthode : subscribe(Subscriber) , parmi lesquels Le but devrait être évident.

Syntaxe

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

2) Flow.Abonné : Il s'abonne aux éditeurs (généralement un seul) pour recevoir des éléments (via la méthode onNext(T)), des messages d'erreur (onError(Throwable) ), ou un signal indiquant qu'aucun autre élément n'est attendu (onComplete()) Avant qu'une de ces choses ne se produise, l'éditeur appelle onSubscription(Subscription) method.

Syntax

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

3) . Flow.Abonnement : La connexion entre un seul éditeur et un seul abonné L'abonné peut l'utiliser pour demander plus d'articles (request(long)) ou rompre la connexion (cancel()). .

Syntaxe

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

Étapes d'exécution de l'API Flow :

• Tout d'abord, nous devons créer un Éditeur et un Abonné.
• Utilisez Publisher::subscribe pour vous abonner à l'abonné.
• Publisher crée un Subscription et appelle Subscriber::onSubscription afin que l'Abonné puisse stocker l'abonnement.
• À un certain moment, l'Abonné appelle Subscription::request pour demander un certain nombre d'articles.
• L'éditeur transmet les éléments à l'abonné en appelant Subscriber::onNext. Il ne publiera pas plus que le nombre d’articles demandé.
• L'éditeur peut rencontrer un problème à un moment donné et appeler respectivement Subscriber::onComplete ou Subscriber::onError.
• L'abonné peut demander plus d'articles à intervalles réguliers ou se déconnecter en appelant Subscription :: Cancel.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!