How to call blocking IO calls on Mono

I have utility methods look like this.

How to call blocking IO calls on Mono

I have utility methods look like this.

How to sink Mono/Flux while generating?

I’m trying to generate Flux with an initial state,

Can doOnNext’s side-effect be skipped?

I am currently writing a method which needs to add each element into a concurrentHashMap before continuing downstream. E.g.

How can I call blocking IO calls on Mono?

I have utility methods look like this.

How can I call blocking IO calls on Mono?

I have utility methods look like this.

How can I make a Mono that only executes once but can also be interrupted on timeout?

I have some processes that need to run together that they depend on each other and need to run in parallel. But they only need to run once each, and also they need to be cancellable since they are expensive, so if at the end I set a timeout, it should interrupt all ongoin processes.

Unable to publish on threads using Scheduler.newBoundedElastic()

I have the following consumer:

FluxSink leading to memory leaks

Consumer