A race condition has been identified where results are returned to the callback, completed is set to true and a call to request(n) comes in on another thread at the same time that calls onComplete before the callback result is passed to onNext.