Top "Project-reactor" questions

How to log request and response bodies in Spring WebFlux

I want to have centralised logging for requests and responses in my REST API on Spring WebFlux with Kotlin. So …

spring-boot kotlin project-reactor spring-webflux

How to check if Mono is empty?

I'm developing a app with Spring Boot 2.0 and Kotlin using the WebFlux framework. I want to check if a user …

spring kotlin project-reactor reactive

Akka or Reactor

I am in the process of starting a new project (java-based). I need to build it as a modular, distributed …

java spring akka reactor project-reactor

How to handle errors in Spring reactor Mono or Flux?

I have below code retuning Mono<Foo>: try { return userRepository.findById(id) // step 1 .flatMap(user -> barRepository.…

spring project-reactor reactive-streams

How to convert Mono<List<String>> into Flux<String>

I'm converting small project written in RxJava 1.x to Reactor 3.x. All is good, except that I could not find …

java project-reactor

Correct way of throwing exceptions with Reactor

I'm new to project Reactor and reactive programming in general. I'm currently working on a piece of code similar to …

java reactive-programming project-reactor reactor

How to correctly read Flux<DataBuffer> and convert it to a single inputStream

I'm using WebClient and custom BodyExtractorclass for my spring-boot application WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept(…

java spring project-reactor spring-webflux reactive-streams

block()/blockFirst()/blockLast() are blocking error when calling bodyToMono AFTER exchange()

I am trying to use Webflux to stream a generated file to another location, however, if the generation of the …

java reactive-programming spring-webflux project-reactor

What kind of "EventBus" to use in Spring? Built-in, Reactor, Akka?

We're going to start a new Spring 4 application in a few weeks. And we'd like to use some event-driven architecture. …

multithreading spring akka event-driven-design project-reactor

Convert from Flux to Mono

How can I convert from a Flux with 1 element to a Mono? Flux.fromArray(arrayOf(1,2,1,1,1,2)) .distinct() .take(1) How do I …

project-reactor