Need to explore the unsubscribe of `recursiveScheduler`: https://github.com/ReactiveX/RxJava/blob/34dce48b4d591a2c574839b4527cbc30cb69e5a2/src/main/java/rx/internal/operators/OperatorObserveOn.java#L122 It seems to wrap with `child.add(scheduledUnsubscribe)` and then defeat that with `child.add(recursiveScheduler)`.