Java reactor how to properly start async cancellable sideeffect

I’m trying to write something using reactor which I know how to write using completable futures. I’m getting “Calling subscribe in non-blocking scope” warning in it. My goal is to call …

Asynchronous Programming and Reactive Programming

This question is in my mind about a year. Actually are there any differences in Asysnchronus and Non-blocking. When we call the blocking part in our code then it becomes blocking which is synchronous …

Merge two api responses into one using Webclient – Webflux

I’m using WebFlux and WebClient and I need to consume two APIs and merge its responses. The first API receive type and document number and returns a list with one element that contains customer data (…

How to handle file access in a reactive environment

I’m refactoring some blocking code to reactive (using Reactor). I think most of the methods in the java.nio.file.Files class are blocking. Is it right if I replace a method like: public boolean exists(…

Use case of Flux and Mono

I am new to world of Flux and Monos, and recently, while using the findAll() method, I realized that this method is capable of returning partial responses , i.e via the Flux , and I need to do append …

RSocket retrieveFlux() with Kotlin

I am trying to write a client for my server (both in Kotlin and using Spring Reactive Web). I encountered this problem while trying to use the RSocket. How can I get a Flux using RSocket? @Component …

WebFlux – how to check if Mono>> is empty to return 404

My code: public Mono>> allGroups( @PathVariable(value = “email”) String email, ServerWebExchange exchange) { return Mono.just( …

Obtaining a nested objects using Spring Data R2DBC

I’m new to Project Reactor and R2DBC. How to receive and merge Flux with Mono properly using Spring Data R2DBC reactive repositories? Parent: @Table(“parent”) public class …