Website about Reactive Programing written on non-reactive website with static pages.
If you want to write a responsive application with some computation, you need to use concurrency. For this purpose ReactiveX has Schedulers, which can be defined during creating data stream.
Sometimes you do not want to onError method of Observer be called. Or you want to react only on some specific event of the lifecycle of Observable. Functions for both of these things are in this post.
Combining operators combine two Observables together by creating new Observable with items from source Observables.
In this post, we will look differences between RxJava and Java stream. Where which use and if they are compatible with each other.
In Java 8 were introduced stream api, which is similar to Reactive Programming streams. So, let's look on this interface with some examples.