thomasnield
05/29/2017, 6:25 PMObservable.interval(), then need to proof-of-concept a few combining operators. I need to explore the best way to implement Subscriber and Subscription to handle Job cancellation. Also, certain sources like Observable.just() do not need jobs until subscribeOn() or observeOn() is introduced, but operators like take() require early termination.