rxjava behaviour of onErrorResumeNext

Question

我很难得到观察者。

Subscriber orchestratorObserver = new Subscriber<Integer>() {
    @Override
    public void onCompleted() {
        System.out.println("orchestratorObserver."+"onCompleted()");
    }
    @Override
    public void onError(Throwable e) {
        System.out.println("orchestratorObserver."+"onError()"+e.getMessage());
    }
    @Override
    public void onNext(Integer i) {
        System.out.println("orchestratorObserver."+"onNext() : "+i);
    }
};
@Test
public void rxTest() {
    Observable.range(0,5)
            .doOnNext(new Action1<Integer>() {
                @Override
                public void call(Integer integer) {
                    throw new RuntimeException("chain error!!");
                }
            })
            .onErrorResumeNext(Observable.just(-1))
            .subscribe(orchestratorObserver);
}
@Test
public void rxTest1() {
    final Observable<Integer> errorTrainObservable = Observable.defer(
            new Func0<Observable<Integer>>() {
                @Override
                public Observable<Integer> call() {
                    return Observable.error(new RuntimeException("source error"));
                }
            });
    errorTrainObservable.onErrorResumeNext(Observable.just(-1));
    errorTrainObservable.subscribe(orchestratorObserver);
}

so rxtest（）输出：

orchestratorObserver.onNext() : -1
orchestratorObserver.onCompleted()

rxtest1（）输出：

orchestratorObserver.onError()source error

我希望rxtest1输出与rxtest相同的ONNEXT事件 - 我该怎么做？即，我想吞下错误并发出错误的值。

如果错误在源源，它的行为似乎是奇怪的 - 但是，如果错误是链，它的行为是另一种方式？如果您可以向我解释这一点：）

Answer 1

这些行：

errorTrainObservable.onErrorResumeNext(Observable.just(-1));
errorTrainObservable.subscribe(orchestratorObserver);

您使用错误处理程序创建Observable，然后将其扔掉，然后订阅无错误处理程序的可观察到的。