Environment: Spring Boot 2.3.1, Java 11 I have tried out a few things already (also comparing with the sample-app by spring), but so far I have been unsuccessful in creating a WebClient that requir...

The Angular Server Sent Event this.eventSource.onmessage call fails with an error "EventSource's response has a MIME type ("application/json") that is not "text/event-stream". Aborting the connecti...

In my handler function I have this method public Mono<ServerResponse> itemsEx(ServerRequest serverRequest) { throw new RuntimeException("RuntimeException Occured"); } Now, I want ...

I believe it is a standard to log request and response in order to track down any issues reported by users and also to integrate it with tools like Splunk. I've found 2 approaches so far, but none ...

I've got a project with the following dependencies: <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId&...

Is it possible to do something like the code below? I have one service that makes an API call and another one which returns a stream of values. I need to modify every value by the value returned by...

What's the difference between creating a Flux directly by calling Flux.push and use the sink within push's lambada expression vs. using a sink provided by a DirectProcessor? In a minimal example w...

I'm trying to add a conditional Retry for WebClient with Kotlin Coroutines + WebFlux.fn + reactor-addons: suspend fun ClientResponse.asResponse(): ServerResponse = status(statusCode()) .headers ...

I am using spring cloud gateway as edge server. This is the flow If request has a header named 'x-foo' then find the header value, get a string from another server and send that string as respons...