Convert From Flux To Mono


Answer :

Instead of take(1), you could use next().



This will transform the Flux into a valued Mono by taking the first emitted item, or an empty Mono if the Flux is empty itself.



Here is a list:




  • Flux#single will work if there is one element from Flux. Eg: flux.take(1).single();


  • Flux#next will get you the first element. Eg: flux.next();


  • Flux#last for last element. Eg: flux.last();


  • Flux#singleOrEmpty is similar to Optional. Eg: flux.take(0).singleOrEmpty();


  • Flux#collect, it depends on use case.



    flux.collect(Collectors.reducing((i1, i2) -> i1))
    .map(op -> op.get());

  • Flux#elementAt for i'th index. Eg: flux.elementAt(1);


  • Flux#publishNext for first found element. flux.publishNext();


  • Flux#reduce for reduction op. Eg: flux.reduce((i1,i2) -> i1);




Comments

Popular posts from this blog

Converting A String To Int In Groovy

"Cannot Create Cache Directory /home//.composer/cache/repo/https---packagist.org/, Or Directory Is Not Writable. Proceeding Without Cache"

Android How Can I Convert A String To A Editable