Questions tagged [reactive-programming]
Reactive Programming is a programming paradigm oriented around data flows and the propagation of change.
reactive-programming
5,743
questions
-1
votes
1
answer
24
views
Reactor doOnError - How to include multiple Exception Types in method parameters
I would like to handle multiple exceptions in the same way in the Controller of a Reactive Spring Boot API.
The idea is to send a HttpStatus.BAD_REQUEST as an error response for more than one type of ...
0
votes
0
answers
10
views
SubscriberContext state in case of concurrent HTTP Request in spring reactive
I have an HTTP API written in Spring Reactive which fetches user details from the datastore. I am adding the description for the API below.
@Configuration
class Routes {
@Bean
fun router() = ...
- 88
0
votes
1
answer
30
views
Need to run in parallel way with Uni in mutiny
public void initialize(@Observes StartupEvent ev) {
UniJoin.Builder<Integer> builder = Uni.join().builder();
Stream.of(1,2,3,4).forEach(r -> {
builder.add(consultrecord(r));
...
-1
votes
0
answers
52
views
Non blocking Processbuilder output
When using ProcessBuilder, is there a true non blocking reactive way to consume the output? By true non blocking i mean not creating a thread that is blocked waiting to read, but push-based like ...
- 389
0
votes
0
answers
38
views
"Too long maps chain. May cause performance overhead"
Idea flags code usage that has more than 2 maps:
single
.map(...)
.map(...)
.map(...)
There is no other explanation for it and I couldn't find any documentation except for this https://...
- 3,171
2
votes
0
answers
37
views
Is There any thread listening for a reply from the external resource? [duplicate]
I'm discovering reactive programming with Spring WebFlux and Netty. When we call some external service we make a request with WebClient, receive a publisher(Mono or Flux) and at the same moment ...
-2
votes
0
answers
24
views
Skip or handle failure in Mutiny Multi.createFrom().iterable in Quarkus and reactive programming
I'm implementing a functionality to read messages from a queue in SQS in AWS, process them and insert them into a table in dynamoDB.
I'm using quarkus and reactive programming with Mutiny to run all ...
- 504
0
votes
0
answers
9
views
Mono.timeout not working on Callable on blocking RestTemplate
I have this method:
private Mono<MyDTO[]> doRequest(List<Request> requests) {
return Flux.fromIterable(requests)
.map(Request::getParams)
.buffer(config.getBatchSize())
...
- 803
1
vote
1
answer
31
views
Overlapping Buffer with Closing Selector
I have a stream of mouse events that emit whilst the user drags the mouse cursor on the screen whilst the button is clicked. I want to perform a pairwise operation on these events and can do this ...
- 9,373
0
votes
1
answer
111
views
Mono.just and non-reactive spring boot
I've recently started working with Spring Boot in a new project that has the following code (simplified):
@RestController
@RequestMapping("/users")
public class MyController {
@Autowired
...
- 41.6k
1
vote
0
answers
78
views
Execute multiple Mono in parallel and combine results without blocking
I am writing a micro-service that calls for a few other microservices.
Some of the services that are being called are independent, while other services are dependent on the response of the previous ...
- 1,506
0
votes
0
answers
33
views
.NET 6 - Accessing Rx Subject Element Concurrently And RAM Optimization While Using TCPClient
I have a .NET 6 project that reads market data from remote socket via TCPClient, process the data, and streams the processed data as socket. But the trick is, there are 2 markets. One is for delayed (...
- 353
0
votes
1
answer
30
views
Reactive variable updated from parent and child component
I have a parent component (List) which displays a list of child components (Block). Nested blocks have a button that allows the user to add/remove them to the selection.
The List component also ...
- 471
0
votes
1
answer
31
views
How to read master DB table into a Map using flux and spring boo t reactive programming
I am new to reactive programming.
My need is to populate all master data into a Hashmap from master data table at service start.
I am using reactive to get flux of master data as below
The above code ...
- 319
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