AbstractOnSubscribe to help build Observables one onNext at a time.
Merge pull request #1946 from akarnokd/AbstractOnSubscribe2

AbstractOnSubscribe to help build Observables one onNext at a time.