Top "Project-reactor" questions

Reactor is a foundational library building for reactive fast data applications on the JVM.

How to cancel an ongoing Spring Flux?

I'm using a spring flux to send parallel requests to a service, this is very simplified version of it: Flux.…

spring reactive-programming spring-webflux project-reactor
How to convert List<Mono<T>> to Mono<List<T>>?

I have a method that returns Mono<Output>: interface Processor { Mono<Output> process(Input input); } And …

java project-reactor reactor
onErrorResume not working as expected

I'm trying to use WebFlux and I'm seeing a behavior I don't quite understand, I suspect this is a bug …

java spring project-reactor spring-webflux
Pass a context from one flux/mono to another

Interesting things happen inside the webflux package. However, my journey in the source didn't solve the following question. Let's say …

java spring-webflux project-reactor
How do I sum the values in a Reactor Flux stream?

Suppose I have a repository with a findAll() method that returns an Iterable of State, where State is a class …

java reactive-programming project-reactor
Combining result from Flux to result from Mono

I started using Project reactor and one place where I'm struggling little is how do I combine things coming from …

spring-webflux project-reactor reactive-streams
Reactive WebClient not emitting a response

I have a question about Spring Reactive WebClient... Few days ago I decided to play with the new reactive stuff …

spring reactive-programming project-reactor spring-webflux
How to return Mono<B> from Mono<A> on error?

Let's say i have the following chain: public Mono<B> someMethod( Object arg ) { Mono<A> monoA = …

java reactive-programming project-reactor reactive-streams
Mono.Defer() vs Mono.create() vs Mono.just()?

Could someone help me to understand the difference between Mono.defer(), Mono.create() and Mono.just()? How to use it …

spring-webflux project-reactor
What is the best way to validate request in a Spring Webflux functional application

In a traditional web application it is easy to validate the request body in the controller method, eg. ResponseEntity create(@…

spring functional-programming bean-validation project-reactor spring-webflux