reactive-programming Questions
2
I am trying to implement a specific Wizard component which user can consume using the pattern below.
<Wizard {...wizardProps} onFinish={this.handleFinish}>
<WizardStep onValidate={() =&g...
Forbidding asked 12/1, 2019 at 12:7
2
Solved
In (Java) reactive programming, what is the difference between a Future<T> and a (Project Reactor) Mono<T>? Both seem to be means for accessing the result of an asynchronous computation...
Jac asked 17/1, 2019 at 15:7
2
Solved
I'd like to return a value (or publisher) after a Flux is completed. Here's an example with (pseudo) code that resembles what I'm after:
val myId : Mono<String> = fetchMyId()
myId.flatMap { ...
Glycol asked 22/1, 2019 at 12:56
1
Given Hystrix going into mainentance mode, I've been working on migrating a (rather large) codebase to Resilience4j.
I make heavy use of the following pattern with Hystrix:
new HystrixCommand<...
Guzel asked 17/1, 2019 at 15:16
1
Solved
I'm relatively new to reactive programming and Reactor. I have a situation in which I want to bufferTimeout values in my stream while keeping it under my control (no unbounded request), so I can ma...
Siva asked 11/1, 2019 at 17:32
1
Solved
So my use-case is to consume messages from Kafka in a Spring Webflux application while programming in the reactive style using Project Reactor, and to perform a non-blocking operation for each mess...
Simonides asked 10/1, 2019 at 10:7
1
I using spring Spring boot 2.1.0.
public Mono<ServerResponse> getConvertXmlToJson(ServerRequest serverRequest) {
Mono<String> requestString = serverRequest.bodyToMono(String.class);
...
Bertiebertila asked 13/11, 2018 at 3:41
3
Solved
I am currently working on a project. In that project, I am printing console.log but no messages are printing anywhere.
I am using npm and react-native-cli to run on a real android device.
Thanks
Tigrinya asked 25/12, 2018 at 5:16
1
Solved
I would like to use 2 approaches(reactive and standard) in one project.
I tried to migrate one REST API endpoint to reactive webflux and test performance before migrate rest of them. But it didn't...
Tidewater asked 21/12, 2018 at 10:24
4
Spring 5 introduces the reactive programming style for rest APIs with webflux. I'm fairly new to it myself and was wondering wether wrapping synchronous calls to a database into Flux or Mono makes ...
Essentialism asked 17/2, 2017 at 13:40
1
Solved
I'm new to project Reactor and reactive programming in general.
I'm currently working on a piece of code similar to this:
Mono.just(userId)
.map(repo::findById)
.map(user-> {
if(user == nul...
Predestination asked 3/12, 2018 at 14:3
2
Solved
I have a paginated response from an URL, I want to keep on hitting the next page URL which I get from the previous response and keep on collecting items till I don't have a "nextPage" URL in my res...
Calipee asked 13/11, 2018 at 5:45
1
I am doing a POC with Spring WebFlux on Tomcat. The stack is totally reactive and using Spring Reactor and Reactive Couchbase.
When I added load on the System, I saw that the number of threads in...
Biggs asked 18/11, 2018 at 14:48
1
Solved
I'm trying to configure a reactive WebClient to use 2-way TLS. I used this answer as a reference. (The one using a WebClientCustomizer, not the one using an InsecureTrustManager).
I double-checked ...
Mathewson asked 16/11, 2018 at 16:11
1
Solved
Thanks to @GlennWatson for pointing out that I needed to add a reference to the Nuget Package ReactiveUI.WPF, in addition to the ReactiveUI package.
I have a ReactiveObject view model, within whic...
Amnesty asked 6/11, 2018 at 11:3
3
Solved
Here, I am trying to make asynchronous and non-blocking calls using reactor and for each request, I may have to call two services in sequence (in my case below, getAccountInfoFromAAA and getAccount...
Drunken asked 26/10, 2018 at 19:11
1
Solved
I'm looking for reactive state libraries like Mobx for Python, i.e. on server-side rather than client-side of a web application.
Mobx is similar to classic reactive libraries like RxPY, but has a ...
Jorgensen asked 14/12, 2017 at 8:6
1
I have a static field
private static Subscription timer;
and two static methods:
public static void setTimer() {
timer = Observable.interval(2, TimeUnit.SECONDS, Schedulers.computation())
....
Cerussite asked 1/7, 2016 at 22:19
1
Solved
I have recently started using reactive and created a simple application which uses reactive streams.
I have the following code which I get an employee by empID. I have to provide extra details abo...
Snafu asked 19/9, 2018 at 16:9
4
I was talking to a colleague who pointed me to the SO question about subjects being considered harmful. However, I have two cases where I have some non-deterministic code that does not seem reasona...
Alexina asked 26/5, 2014 at 3:22
1
Solved
I'm probably missing something but I can't figure out what it is.
The following code does nothing at all:
webClient.get().uri("/some/path/here").retrieve()
.bodyToMono(GetLocationsResponse.clas...
Toshikotoss asked 17/9, 2018 at 21:6
1
Solved
I want to prevent my UIButtons from emitting RX tap events until some control stream indicates that it is ready. I want buttons to be disabled again if the control stream reverts back to not ready....
Kryska asked 9/9, 2018 at 11:4
1
Solved
I'm a starter in Spring Web-Flux. I wrote a controller as follows:
@RestController
public class FirstController
{
@GetMapping("/first")
public Mono<String> getAllTweets()
{
return Mon...
Salute asked 9/9, 2018 at 13:4
2
Solved
I have to ways of doing the same thing, although I prefer the first one. But the first approach doesn't seem to work. (the tap() is not triggered)
// does not work
this.actions$.pipe(
ofType(Layo...
Tergal asked 5/9, 2018 at 15:29
1
Solved
I'm new to Flutter and I'm trying to accomplish a simple thing:
I want to create a signup functionality using BLoC pattern and streams.
For the UI part I have a stepper, that on the very last ste...
Profanity asked 4/9, 2018 at 13:50
© 2022 - 2024 — McMap. All rights reserved.