5,765 questions
0
votes
1
answer
74
views
RxJava Maybe.doFinally() executing much later than doOnSuccess() in high-throughput multithreaded environment
I'm experiencing a confusing timing issue with RxJava's Maybe operators in a high-throughput service (40 TPS) with concurrent execution. I have two classes that log execution times, but they're ...
- 419
1
vote
1
answer
27
views
Looking for a correct way to validate mssql Query
public Mono<String> queryValidation(String connectionId, String query) {
return connectionConfigRepository.findByConnectionId(connectionId)
.switchIfEmpty(Mono.error(new ...
- 11
1
vote
0
answers
17
views
In Spring WebFlux, on which thread is the request handled when entering a controller?
I'm not good at English, so I used a translator, so please understand that the sentences may be strange.
I'm learning Spring WebFlux.
When a request entering a controller, requests are received on a ...
- 11
2
votes
1
answer
129
views
How to read this marble diagram?
I have already gone through https://projectreactor.io/docs/core/release/reference/apdx-howtoReadMarbles.html.
But I cant seem to understand, how this would map to here. Where does subscribe, ...
- 95
0
votes
0
answers
36
views
Missing MDCContext from kotlin web flux
I have a spring web flux based application, written in kotlin I am adding few information in reactor context by using web filter. I also have logging information which I set in MDCContext but I am ...
0
votes
1
answer
140
views
Spring WebFlux caching with Caffeine
I am having trouble understanding how to cache Reactive streams using the spring-data-starter-cache library. From tutorials such as https://www.baeldung.com/spring-webflux-cacheable, I see that they ...
- 1,217
2
votes
1
answer
65
views
Is there an auto-increment feature or approach for Spring Boot MongoDB entities in a reactive save API?
I have a Spring Boot microservice that provides non-blocking APIs for creating and managing entities called Product. The services uses a MongoDB. For design purposes, each Product needs to have a ...
- 415
0
votes
1
answer
58
views
repo.save() and repo.findById() does not work within the save reactive pipeline
I am trying a trivial test with a basic Spring Boot 3.4 application and the reactive MS Server driver r2dbc-mssql.
repo.save(User.builder().name("Joe Smoe").build())
.doOnNext(...
- 13
0
votes
0
answers
54
views
Spring Cloud Gateway - Request Body Consumed in Filter, Response Not Returned to Client (Empty Response Body)
I'm building a Spring Cloud Gateway filter that reads the request body to validate a payload signature before forwarding the request to downstream services (like an account service for login).
The ...
- 670
0
votes
0
answers
34
views
WebFlux with WebFilter - correctly starting a long running task inside of a WebFilter without blocking response
Given a org.springframework.web.server.WebFilter - what are some best ways to start a "longer running" thread without blocking the REST response coming back to the consumer. The long running ...
- 1,450
1
vote
0
answers
37
views
Transforming a reactive API into a lazy sequence in Kotlin
Consider I have a reactive, push-style API such as Files.walkFileTree() from NIO.2. Now, I want to transform this API to produce a lazy sequence of items (Sequence<T>) instead.
This is fully ...
- 5,460
2
votes
0
answers
100
views
Why does WebClient in WebFlux switch from virtual thread to platform thread after async boundary?
I'm exploring the use of virtual threads (Java 21) in a Spring WebFlux application by using a custom Scheduler backed by a virtual thread executor via .subscribeOn().
However, I’ve noticed that while ...
0
votes
1
answer
114
views
Reactive endpoints in Quarkus returning swapped results
I'm pretty new to the whole reactive/mutiny/vert.x world and I have the following issue I can't quite figure out:
I've got two REST endpoints, they both retrieve some data (a count) for a certain ...
1
vote
1
answer
81
views
How to select certain row(s) by code in a DataGrid table in Python-Shiny?
I created a table ("DataGrid") using:
ui.output_data_frame("grid")
which I filled using
@render.data_frame
def grid():
df = ...
return render.DataGrid(df, ...
- 630
0
votes
0
answers
40
views
Reactive Spring and Reactive mongo, second save sometimes executed sometimes not
could someone help me to understand why this is happening:
Tech stack: spring boot 3, java 21, reactive spring, mongo
Let's say we have object like this:
public class User {
private Long id;
...
- 1