``` Observable.merge( Observable.i...

# rx

[ursus]

Observable.merge(
                Observable.interval(0, 300, TimeUnit.MILLISECONDS).map(__ -> "aaa" + __),
                Observable.interval(0, 500, TimeUnit.MILLISECONDS).map(__ -> "bbb" + __))
                .observeOn(Schedulers.single())
                .flatMap(s -> Observable.fromCallable(() -> {
                    Log.d("Foo", "processing start   s=" + s);
                    Thread.sleep(3000);
                    Log.d("Foo", "processing end   s=" + s);
                    return 0;
                }))
                .subscribe();