'Cascade Flux results

I have two actions in Mono, both returning similar object - Mono action1() Mono action2()

I tried doing - Flux1.blockFirst(); Flux2.blockFirst();

both of the flux are performing the action I want. But one of the requirement is if any action fails then both flux should fail or call action to revert the previous action.

javaspring-bootmonospring-webfluxflux


Solution 1:[1]

Looks like Flux.zip(flux1, flux2).... is what you're looking for:

public static <T1,T2> Flux<Tuple2<T1,T2>> zip(Publisher<? extends T1> source1,
                                              Publisher<? extends T2> source2)

Zip two sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple2. The operator will continue doing so until any of the sources completes. Errors will immediately be forwarded. This "Step-Merge" processing is especially useful in Scatter-Gather scenarios.

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#zip-org.reactivestreams.Publisher-org.reactivestreams.Publisher-

There are various overloads with different number of publishers to combine and possible specification of a combinator function.

Also, some other ways to combine publishers are described here: https://www.baeldung.com/reactor-combine-streams

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source
Solution 1 dekkard

Related Questions