Mono et Flux

À partir des items de l’observable Flux ou Mono initial, il résulte un autre observable issu de la transformation du premier observable par une large variété d’opérateurs de chaînage sur le flux qu’il contient. La fin du traitement du flux d’items de l’observable d’origine est détectée et permet de faire une action dédiée. Une fin prématurée du traitement du flux par les opérateurs déclenche également une action spécifique. Flux Mono

Action

Signification

onNext

L’élément suivant est traité.

onCompleted

Le flux d’entrée est vide.

onError

Il y a une erreur lors de la transformation de l’élément actuellement traité dans le flux.

Nous sommes en Java 8 et les actions sont disponibles directement via des lambdas.

Flux<Integer> flux = Flux.create(subscriber -> { 
   subscriber.next(1); 
   subscriber.next(2); 
   subscriber.onCompleted(); 
}); 
 
Cancellation cancellation = flux.subscribe( 
       val -> log.info("Subscriber received: {}", val),    //--> onNext 
       err -> log.error("Subscriber received error", err), //--> onError 
       () -> log.info("Subscriber got Completed event")    //--> onComplete 
); 

1. Opérations...

Pour consulter la suite, découvrez le livre suivant :
couv_EPREAJASP.png
60-signet.svg
En version papier
20-ecran_lettre.svg
En version numérique
41-logo_abonnement.svg
En illimité avec l'abonnement ENI
130-boutique.svg
Sur la boutique officielle ENI
Précédent
Reactor
Suivant
Contre-pression