The following block of code assumes RxJava2 usage.Please, describe which scheduler will [map] execute on, [filter] execute on. fun theTest() { val io = Schedulers.io() Observable .just("long", "longer", "longest") .subscribeOn(Schedulers.io()) .map { println("map ${Thread.currentThread().name}") it.length } .observeOn(Schedulers.computation()) .filter { println("filter ${Thread.currentThread().name}") it > 6 } .blockingSubscribeBy { length -> println( "item length $length under " + Thread.currentThread().name ) } }
