5,760 questions
Advice
0
votes
2
replies
46
views
In Vert.x 5, in a Future composition - how to execute an async operation regardless of the failure state
I have a workflow that I need to asynchronously cleanup after - without losing the completion value or failure state. In essence I need an onComplete() that returns a completion.
In Java's ...
- 32.9k
2
votes
1
answer
137
views
Why should I return a Publisher instead of throwing an exception in Spring WebFlux?
In Spring WebFlux, when working with reactive streams , why is it recommended to return a Publisher (like Mono.error()) instead of throwing an exception directly within a stream?
I saw this question ...
- 452
Advice
0
votes
1
replies
65
views
Why doesn't R2DBC support features like lazy loading, cascading operations, or dirty checking, which are available in JPA?
I'm working with Spring Data R2DBC in a reactive application and noticed that it doesn't support features like lazy loading, cascading operations, or dirty checking, which are commonly found in JPA ...
- 452
3
votes
2
answers
142
views
How to implement a "new" indicator that highlights a change for x seconds with Rx.Net?
I'm trying to implement a ViewModel that highlights changes as they happen coming from a external device. I have a working valueObservable that triggers on each change.
I want to highlight each ...
- 722
0
votes
2
answers
99
views
Why doesn't Spring Data R2DBC support Jpa features? [closed]
I'm working with Spring Data R2DBC and am curious about why it doesn't support features like lazy loading, cascading operations, or dirty checking, which are commonly used in JPA.
Could someone ...
- 452
2
votes
1
answer
106
views
How to find the root cause / exception stacktrace of signal type CANCEL
In doFinally have printed the signal type to finally verify that it was a cancellation (CANCEL). However, this is not captured as part of doOnError as technically cancellation is not part of error.
...
- 1,815
0
votes
1
answer
98
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
36
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
37
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
186
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
46
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 ...
1
vote
1
answer
328
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,237
2
votes
1
answer
72
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
84
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
80
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