Top "Project-reactor" questions

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

How to execute blocking calls within a Spring Webflux / Reactor Netty web application

In my use case where I have a Spring Webflux microservice with Reactor Netty, I have the following dependencies: org.…

spring-data-mongodb spring-webflux project-reactor reactor-netty
Reactor mapping Mono<Boolean> to Mono<Void>

I have function that return Mono<Boolean> and I want to map it to Mono<Void> (…

spring project-reactor
The bean could not be injected as a 'Type' because it is a JDK dynamic proxy that implements: reactor.fn.Consumer

My Spring 4 application, which uses Reactor 2, fails to start with: *************************** APPLICATION FAILED TO START *************************** Description: The bean 'orderHandlerConsumer' could not …

java spring project-reactor
Spring Reactor: Mono.zip fails on empty Mono

I am using Spring Reactor 3.1.0.M3 and have a use case where I need to merge Mono's from multiple sources. …

java spring project-reactor
spring webclient: retry with backoff on specific error

i'd like to retry the request 3 times after waiting 10sec when response is 5xx. but i don't see a method …

java spring spring-webflux project-reactor spring-webclient
Spring WebFlux: Only one connection receive subscriber allowed

I am writing a simple app with Spring 5 Webflux and Kotlin. I am trying to implement PUT endpoint in a …

spring-boot kotlin project-reactor spring-webflux reactor-netty
Conditional repeat or retry on Mono with webclient from Spring WebFlux

What i want to do is a conditional repeat on a Mono in Webflux with webclient.The Situation is the …

java spring webclient spring-webflux project-reactor
How to read the request body with spring webflux

I'm using Spring 5, Netty and Spring webflux to develop and API Gateway. Sometime I want that the request should be …

spring-webflux project-reactor spring-cloud-gateway
Adding a retry all requests of WebClient

we have a server to retrieve a OAUTH token, and the oauth token is added to each request via WebClient.…

spring-webflux project-reactor
Project Reactor parallel execution

Project Reactor 3.1.5.RELEASE Consider this: Flux.range(0, 10) .publishOn(Schedulers.parallel()) .subscribe(i -> LOG.info(i)); I am expecting …

java reactive-programming project-reactor