Learning RxJava

Combine latest

The Observable.combineLatest() factory is somewhat similar to zip(), but for every emission that fires from one of the sources, it will immediately couple up with the latest emission from every other source. It will not queue up unpaired emissions for each source, but rather cache and pair the latest one.

Here, let's use Observable.combineLatest() between two interval Observables, the first emitting at 300 milliseconds and the other every one second: 

import io.reactivex.Observable;import java.util.concurrent.TimeUnit;public class Launcher {    public static void main(String[] args) {        Observable<Long> source1 =                Observable.interval(300, TimeUnit.MILLISECONDS);        Observable<Long> source2 =                Observable.interval(1, TimeUnit.SECONDS