5,757 questions
Advice
0
votes
2
replies
60
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 ...
- reputation score 32949
Score of 2
1 answer
148 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 ...
- reputation score 452
Advice
0
votes
1
replies
82
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 ...
- reputation score 452
Score of 3
2 answers
148 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 ...
- reputation score 722
Score of 0
2 answers
135 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 ...
- reputation score 452
Score of 2
1 answer
114 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.
...
- reputation score 1815
Score of 0
1 answer
109 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 ...
- reputation score 419
Score of 1
1 answer
43 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 ...
- reputation score 11
Score of 1
0 answers
43 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 ...
- reputation score 11
Score of 2
1 answer
205 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, ...
- reputation score 95
Score of 0
0 answers
47 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 ...
- reputation score 23
Score of 1
1 answer
374 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 ...
- reputation score 1237
Score of 2
1 answer
77 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 ...
- reputation score 415
Score of 0
1 answer
97 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(...
- reputation score 13
Score of 1
0 answers
57 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 ...
- reputation score 5530