Mono.just(value) is the most primitive – once you have a value you can wrap it into a Mono and subscribers down the line will get it. Mono.defer(monoSupplier) lets you provide the whole expression that supplies the resulting Mono instance. The evaluation of this expression is deferred until somebody subscribes. Inside of this expression you can … Read more
Publish “dynamically” using FluxProcessor and FluxSink One of the techniques to supply data manually to the Flux is using FluxProcessor#sink method as in the following example @SpringBootApplication @RestController public class DemoApplication { final FluxProcessor processor; final FluxSink sink; final AtomicLong counter; public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } public DemoApplication() { this.processor = … Read more