How does one performed batched requests when `AbstractOnSubscribe` invokes `onNext` every time? We should be able to generate a backpressure aware `Observable` that handles function invocation but doesn't prohibit batch performance.