CombineLatestObservable.java

/*  
 * There are 2 Observables each emitting values after an interval of 100 ms and 150 ms
 * respectively. The combineLatest() operator combines both the observables and 
 * emits the result at each particular intervals.
 
 */
Observable<Long> observable1 = Observable.interval(100, TimeUnit.MILLISECONDS);
    Observable<Long> observable2 = Observable.interval(50, TimeUnit.MILLISECONDS);

    Observable.combineLatest(observable1, observable2,
            (observable1Times, observable2Times) ->
                        "Refreshed Observable1: " + observable1Times + " refreshed Observable2: " + observable2Times)
            .subscribe(item -> System.out.println(item));

        Thread.sleep(1000);