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...

couv_EPREAJASP.png

Découvrez 

le livre :

Aussi inclus dans nos :

Précédent
Reactor
Suivant
Contre-pression