Как определить потоки выполнения операторов RxJava в цепочке