you call subscribe(), it posts to computation, goes through map, posts to computation again, goes through observeOn, reaches the emitter. Emitter sends 1 down, observeOn posts to newThread, goes through subscribeOn, hits map, goes through subscribeOn, his the subscriber