All Questions
Tagged with reactive reactive-programming
134
questions
0
votes
1
answer
19
views
RxCpp: Duplicate Data in Windows When Using window_toggle
I'm using RxCpp to process a stream of order data and time slices. My goal is to segment the order data into windows, where each window is defined by three consecutive time slice messages. However, I'...
- 49
-1
votes
1
answer
130
views
How to persist with hibernate-reactive and complex id?
i have an error when i want to persist with Hibernate-reactive (hibernate-reactive-core 2.0.6.Final) & spring-boot & java17.
My entity :
import jakarta.persistence.*;
import lombok.*;
import ...
- 9
0
votes
0
answers
44
views
Webflux Mono Chaining - Multiple dependent service calls with exception handling not working in SpringBoot
I am new to Webclient and reactive programming , have to invoke multiple service which are dependent on, I am not able to handle the exception in each stage. Any help appreciated
ServiceOne to get ...
- 1
0
votes
1
answer
27
views
How to load reactiveValues from disk without breaking obervers?
In order to save the state of a shiny application to the disk I am using the function reactiveValuesToList().
When I want to load the state from the disk I am using do.call(reactiveValues, ...) as ...
- 2,021
3
votes
1
answer
2k
views
Handling an empty Mono
I am trying to write a reactive function that performs a certain task when the first Mono is non-empty, and a "fallback" task when the Mono is empty. This is what I have so far:
static Mono&...
- 1,173
0
votes
1
answer
748
views
How to process batch of elements in Flux in parallel environment
In the below piece of code, I see an IDE error for buffer. I want to be able to group elements in to batch of three using buffer but it isn't working.
My goal is, divide flux into parallel rails, and ...
0
votes
2
answers
642
views
Call Different Method in reactive pipeline
I have a use case where I have to call two different methods in a reactive pipeline Java 8 on a post-API call.
1st Method:
will insert data in a master table and will return the pk of that table ...
- 15
2
votes
0
answers
271
views
Events Lost When Consuming using reactor kafka
I am using Reactive kafka for consuming events.
Problem: I pushed 7 events to the queue, but the consumer only consumed 5 of them. (Only happening when deployed on a server, working fine in local ...
0
votes
2
answers
176
views
How can I combine the values from two publishers that are dependent on eachother?
I have the following methods
class A -> Flux<A> getAllA();
class B -> Mono<B> getB(A a);
class C -> Mono<C> getC(A a, B b)
Now Im trying to achieve the following using a ...
- 462
0
votes
1
answer
242
views
mono of map to flux conversion
I want to convert a Mono of map to flux . can anyone help me on that please?
The object that I have is something like
Mono<Map<Integer , Project>>
where map key is the project key
From ...
- 15
0
votes
0
answers
29
views
Skipping incorrect values with onErrorResume
I have RxJava problem with onErrorContinue() which officialy not exist.
Observable.fromIterable(List.of(1,2,3,4,5))
.flatMap(int -> {
if ( p % 2 == ) { return Observable.error(new RuntimeException(&...
- 13
0
votes
1
answer
82
views
Error creating connection to DB in Reactive Spring Boot project
I am trying to establish connection with Cassandra to read data using the reactive dependency of cassandra, and I am getting the following error. What can be the reason for this?
Dependency
...
- 11
0
votes
1
answer
590
views
How to extract value from MonoNext (and convert to byte[])
Map<String,Mono<byte[]>> map = new HashMap<>();
List<User> userList = new ArrayList<>();
map.entrySet().stream().forEach(entry -> {
if (entry.getValue() == null) {...
- 1,446
0
votes
1
answer
475
views
Spring webflux - how to return a DTO in a mono by looking up two concurrent calls that return a Mono and a Flux?
Somewhat new to reactive programming and can't find any good examples of this. How would I combine results from a Mono and a Flux (concurrent fetches) to return a Mono of a DTO?
I know the code below ...
1
vote
2
answers
165
views
How to add andThen() in a Completable.complete() programmatically in Rx / Reactive Java
how do i make a chain of andThen() operator on an Completable ?
for example, the original code is this:
return Completable.complete()
.andThen(processdata("01"))
.andThen(...
- 11