2 semantics, 1 way to make them run in parallel The two options I present below both need some additional tuning to make A and B Mono run in parallel: namely, each Mono should use subscribeOn(Scheduler) to get out of the common thread from where they’re merged. If you only care about the completion of … Read more
In short: Flux::create doesn’t react to changes in the state of the app while Flux::generate does. The long version Flux::create You will use it when you want to calculate multiple (0…infinity) values which are not influenced by the state of your app and the state of your pipeline (your pipeline == the chain of operations … Read more
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.