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#singlewill work if there is one element fromFlux. Eg:flux.take(1).single();Flux#nextwill get you the first element. Eg:flux.next();Flux#lastfor last element. Eg:flux.last();Flux#singleOrEmptyis similar toOptional. Eg:flux.take(0).singleOrEmpty();Flux#collect, it depends on use case.flux.collect(Collectors.reducing((i1, i2) -> i1))
.map(op -> op.get());Flux#elementAtfor i'th index. Eg:flux.elementAt(1);Flux#publishNextfor first found element.flux.publishNext();Flux#reducefor reduction op. Eg:flux.reduce((i1,i2) -> i1);
Comments
Post a Comment