Operators and functionality necessary for backpressure. Tests to show interoperability with backpressure-enabled Observables.