Maybe this ``` if (t != null) { if (!(t instanceof CancellationException && emitter.isDisposed())) emitter.onError(unwrapException(t)); } else { emitter.onSuccess(val); } ```