scheduler.Schedule()they have is slightly more complicated, with recursive scheduling and more fun stuff.
Subscription. Is there a use case for doing
Observable.OnSubscribe#call(subscriber)? Would all
onCompletedetc. calls that pass through the original subscriber be forwarded to the secondary subscriber?
onNextand do the processing on those lines inside
mapor other operators?