Contract Change

Change contract for onComplete/onError to not need to wait on the acknowledgement of the previous onNext (i.e. no back-pressure for onComplete/onError).