Observable <Integer> observable = Observable.just(1, 2, 3, 4, 5, 6);
observable .doOnNext(integer -> println("Emitting item " + integer + " on: " + currentThread().getName()))
.map(integer -> integer * 3)
.filter(integer -> integer % 2 == 0)
.subscribeOn(Schedulers.computation())
.subscribe(integer -> println("Consuming item " + integer + " on: " + currentThread().getName()));