Top "Reactive-programming" questions

How to handle exceptions thrown by observer's onNext in RxJava?

Consider the following example: Observable.range(1, 10).subscribe(i -> { System.out.println(i); if (i == 5) { throw new RuntimeException("oops!"); } }, …

java system.reactive reactive-programming rx-java

Make Http call using ReactiveX for Java

I am new to ReactiveX for Java and I've the following code block that make external http call but it …

java asynchronous reactive-programming resttemplate reactivex

What's the correct way to get the response body from a WebClient in an error case?

I'm new to WebClient and reactive programming. I want to get the response body from a request. In case of …

spring-boot reactive-programming spring-webflux spring-webclient

FormControl.detectchanges - why use distinctUntilChanged?

Reading How to use RxJs distinctUntilChanged? and this, it seems that distinctUntilChanged alters the output stream to only provide distinct …

angular rxjs reactive-programming distinct-values

Chaining RxJava observables with callbacks/listeners

I am using Retrofit with Observables, and would like to chain the observables. Usually it works well with functions like …

android reactive-programming rx-java observable rx-android