I want to manually perform page transitions in my Angular2 app. So what I have done so far is produced a service that I call from a Component that deals with navigation. When you click on some link...

I want to call the method when previous returned Mono<Void>: @Override public Mono<Void> sendEmail(EmailDto emailDto) { return mailReactiveClient.sendEmail(message -> createMess...

I have created a ParallelFlux and then used .sequential(), expecting at that point I can count or "reduce" the results of the parallel computations. The problem seems to be that the parallel thread...

I have the below async tasks: public class AsyncValidationTask { // Returns Mono.error(new Exception()) if error, otherwise Mono.empty() public Mono<Void> execute(Object o); } public cla...

I'm making a react native project where user can search images using Flickr API, Everything else is working fine but the problem i'm having while implementing pagination. I have used FlatList...

I am using RxJava. I have an Observable<T>. How do I convert it to List<T>? Seems to be a simple operation, but I couldn't find it anywhere on the net.

I'm a newbie in reactive programming and also Spring Webflux I have a method to get some key from Redis and if this key is null or is not equals to the specified string i want to throw an exception...

Last week I answered an RxJS question where I got into a discussion with another community member about: "Should I create a subscription for every specific side effect or should I try to minimize s...

After reading multiple blog posts and documentation, I came to the conclusion that following doOnSubscribe will be executed on a worker thread: Observable.just(1) .observeOn(Schedulers.io()) .do...

It's been a long time since I started to search for a Flutter ListView library that will allow me to use pagination in a smart way. Sadly I haven't found anything that meets my criteria: Smart pa...

I am trying to implement cache then network strategy for my API call using Kotlin Flows. Here is what I am trying right now flowOf( remoteDataSource.getDataFromCache() // suspending function retu...

I see that ReactiveX (RxJava) has an operator timeout, which will apply to every item in a subscription stream. But I only want to check the very first response with a timeout and do not care about...

For a chat bot I'm refactoring to not require locks for managing most of its state, the website it connects to via websocket throttles messages that can be received from regular users to a rate of ...

I need to perform some tasks. Some of the tasks are independent and some are dependent on successful execution of other tasks. Independent tasks can be run in parallel for better performance. I cal...

In a project using spring reactor, we have detected that the real complexity of the reactive code is not detected by our static analysis tools. At the moment we are using a combination of PMD...

I'm beginning a foray into the world of reactive Java programming using Webflux in Spring Boot. I'm running into a scenario where it's really hard to do a certain database call reactively. If I d...

Below is my attempt at a Apache Camel reactive streams solution to connect a publisher to a subscriber (code for camel routes is shown below) across JVM's To enable the communication to span JVMs...

I am trying to post data using WebTestClient But unfortunately such message is thrown: java.lang.AssertionError: Status expected:<200> but was:<500> > POST http://localhost:41087/m...

I'm developing an Android app using Clean Architecture and I'm migrating it to RxJava 2.x. I have to make some network requests to a soap service, so I defined the api interface in the domain modul...

I am wondering if there is a way to compose existing operators to perform the opposite of a switchMap(). The switchMap() will chase after the latest emission it receives and cancel any Observable...

I see a lot of people with very similar problems, but nothing I try works. CONTEXT I have a list of favorited ideas. Whenever I click in a button inside the ideaItem, it should get removed from t...

I want to have multiple subscriptions to react to an observable event, but I want to log the event as well, so I pipe it through a do() operator in which I do the logging. The problem is, the even...

Previously in rxjs4 there was a method in the BehaviorSubject called: getValue() (doc here). This method does not exist anymore in rxjs5. So the only solution that I found to get the value of a Beh...

I am a beginner of RxJava and I am curious about the meaning of "backpressure". Does it mean that the producer puts pressure behind the consumer's back? Or does it mean that consumers are putting...

I have three Observables which I combine with combineLastest: Observable<String> o1 = Observable.just("1"); Observable<String> o2 = Observable.just("2"); Observable<String> o...