ReactiveX/RxJava — pull request #1931 by akarnokd (2014-12-05 13:08:29+00:00)
Title: AbstractOnSubscribe to help implement backpressure-respecting

observables.

Proposed implementation for #1930. See tests for use cases.