Mono - Flux switchIfEmpty and onErrorResume

user_1973933 0
Viewed 279

In project reactor is it possible to implement a stream with switchIfEmpty and onErrorResume at the same time?

infoRepository.findById(id); //returns Mono<Info>

in case of empty or error then switch to the same backup stream?

flux project-reactor spring-webflux mono spring
1 Answers

There's no single operator that does these things together, but you can trivially switch to an empty publisher on an error, then handle both cases through switchIfEmpty like:

infoRepository.findById(id)
              .onErrorResume(e -> Mono.empty())
              .switchIfEmpty(newPublisher);
user_5514060
Related