When configuring a reactive-stream (via Spouts) asynchronously, it is possible to push data asynchronously that is recieved by onNext before initialization is complete.

Any attempt to send subsequent requests for more data upstream should check for initialization to complete (on the initialization thread), otherwise the upstream subscription won't be available.