Hello everyone My task is to simply make controller that gives me results immediately when they are ready (simple example below) Imagine: I want to get the exac
I am trying to use spring WebClient wc = WebClient.create(); in a non-Spring application, but it looks like DefaultExchangeStrategiesBuilder.DEFAULT_EXCHANGE_ST
I am doing a functionality that allows you to save users, but before that it does a validation to validate if the nick exists in the database, when I run I get
I am new to Springboot reactive I was asked to call the following endpoint and return todays weather data only: https://api.weather.gov/gridpoints/MLB/33,70/for
Small question regarding a Java 11 Spring Webflux 2.6.6+ web app, containerized and deployed using Kubernetes please. From the web app application logs, I am se
In a Webflux server, detect function first looks up 2 redis hash value, and then do a heavy CPU calculation using the redis returned value, and then save result
I'm trying to understand reactive style. But stuck on this example. public class ScriptServiceImpl implements ScriptService{ private static Logger log = Lo
For Matching condition, return Mono.error from code , but gives compilation error. I commented out //return Mono.error(new RuntimeException("User Phone Exists a
Is there a "default" scheduler in the Project Reactor? Which one is it? By "default" I mean the one used when no subscribeOn() nor publishOn() are called for th
Is there a "default" scheduler in the Project Reactor? Which one is it? By "default" I mean the one used when no subscribeOn() nor publishOn() are called for th
Small question regarding Java + SpringBoot Webflux please. I have a small handler returning a Flux<MyPojo> If I build a controller as such (please note th
I am having a spring webflux based GraphQL application. The application is configured as resourceServer and I am able to access the /graphql endpoint by passing
I have a scenario, where I am using the State pattern. Every Start has an Action defined. We start with an initial state and an initial Action and then keep goi
I have a WebFlux handler as below. @Transactional public Mono<ServerResponse> submitOrder(final ServerRequest request) { return context.retrieveUser
I am trying to make an SSE Spring application, using Webflux. According to the documentation, the message is not sent to the sink if there is no subscriber. In
Since SecureRandom is slow, I was wondering how to make it so that I have a Flux that I can request the next random number, but it is prepopulated by say 100 it
I'm trying to implement Spring Security authentication on Spring WebFlux app. I have implemented Spring Security authentication on Spring Web before. When I rea
Small question regarding database connection metrics for Spring Webflux (2.6+) web application please. For the SpringBoot (non Webflux) apps, connecting to JDBC
Motivation I have a service which I want to make @Transactional. My service is storing complex data in multiple tables, there is a referential integrity between
I'm learning Reative jdbc with R2DBC MySQL. I have a repository like this: public interface VerificationTokenRepository extends ReactiveCrudRepository<Verifi