А можно не проламывать а протестить) Observable.just(1).reduce().doOnNext(i -> test).subscribe() Observable.just(1,2).reduce().doOnNext(i -> test).subscribe()
я это понимаю, но я полтора года уже с ним сношаюсь, а легче не становится, хотя и начал чаще от него кайфовать. Но проломить моник ногой хочется ещё чаще.