Этот код:
Observable.just(1, 2, 3, 4, 5)
.map(x -> x * 2)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(observer);
Выводит в лог 2, 4, 6, 8, 10 (т.е. onNext
отрабатывает 5 раз). Если же применить map(x -> 123
)
Observable.just(1, 2, 3, 4, 5)
.map(x -> 123)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(observer);
то в логи 123 пишется только два раза. Почему так?
upd.:Выключение из цепочки потоков на ситуацию не влияет.