Observable.range(1, 5)
                .map(i -> i * 100)
                .doOnNext(i -> {
                    System.out.println("Emitting " + i + " on thread " + Thread.currentThread().getName());
                })
                .subscribeOn(Schedulers.computation())
                .map(i -> i * 10)
                .subscribe(i -> {
                    System.out.println("Received " + i + " on thread " + Thread.currentThread().getName());
                });