RxJava doOnError 和 onErrorReturn 如何工作？

我做了这些单元测试，结果根本不是我预期的：

// This one outputs "subscribe.onError" 
@Test
public void observable_doOnError_subscribingToError() throws InterruptedException {
    Observable<String> obs = getErrorProducingObservable();
    obs.doOnError(throwable -> System.out.println("doOnError"));
    obs.subscribeOn(Schedulers.immediate()).observeOn(Schedulers.immediate()).subscribe(
        s -> {},
        error -> System.out.println("subscribe.onError")
    );
    Thread.sleep(300);
}

// This one outputs "subscribe.onError" 
@Test
public void observable_onErrorReturn() throws InterruptedException {
    Observable<String> obs = getErrorProducingObservable();
    obs.onErrorReturn(throwable -> "Yeah I got this");
    obs.subscribeOn(Schedulers.immediate()).observeOn(Schedulers.immediate()).subscribe(
        s -> System.out.println("got: " + s),
        error -> System.out.println("subscribe.onError")
    );
    Thread.sleep(300);
}

private Observable<String> getErrorProducingObservable()  {
    return Observable.create(subscriber -> {
        subscriber.onError(new RuntimeException("Somebody set up us the bomb"));
    });
}

因此，两者都输出“subscribe.onError” - 既不叫也不叫。doOnErroronErrorReturn

doOnError记录为：

修改源 Observable，以便在调用 OnError 时调用操作。

我不知道如何理解这一点，但我期望输出“doOnError”或“doOnError”后跟“subscribe.onError”。

onErrorReturn记录为：

指示 Observable 发出一个项目（由指定的函数返回），而不是在遇到错误时调用 onError。

因此，我期望“得到：是的，我得到了这个”作为后一个测试的输出。

什么原因？