MergeUntilComplete

MergeUntilComplete.java

import java.util.concurrent.TimeUnit;

import rx.Observable;

public class MergeUntilComplete {

    public static void main(String[] args) {

        Observable<String> t1 = Observable.timer(0, 100, TimeUnit.MILLISECONDS).map(i -> "A-" + i);
        Observable<String> t2 = Observable.timer(0, 300, TimeUnit.MILLISECONDS).take(5).map(i -> "B-" + i);

        Observable.merge(t1.materialize(), t2.materialize()).takeWhile(n -> n.isOnNext())
                .dematerialize().toBlocking().forEach(System.out::println);
    }
}

output.txt

A-0
B-0
A-1
A-2
A-3
B-1
A-4
A-5
A-6
B-2
A-7
A-8
A-9
B-3
A-10
A-11
A-12
B-4