android - 防止OnErrorNotImplementedException

我想实现以下目标:如果我调用Obervable.subscribe(Action1)方法，它不会在任何地方抛出OnErrorNotImplementedException，但是如果我调用Obervable.subscribe(Action1, Action1)，则在正常引发错误时调用第二个操作。我尝试了两种方法:

.onErrorResumeNext(Observable.empty())

这样就不会抛出OnErrorNotImplementedException，但是如果我也通过了第二个 Action ，则该 Action 就不会被调用。

第二:

.lift(new Observable.Operator<T, T>() {
    @Override
    public Subscriber<? super T> call(Subscriber<? super T> subscriber) {
        return new Subscriber<T>() {
            @Override
            public void onCompleted() {
                if (!subscriber.isUnsubscribed()) {
                    subscriber.onCompleted();
                }
            }

            @Override
            public void onError(Throwable e) {
                if (!subscriber.isUnsubscribed()) {
                    try {
                        subscriber.onError(e);
                    } catch (Throwable t) {
                        if (!(t instanceof OnErrorNotImplementedException)) {
                            throw t;
                        }
                    }
                }
            }

            @Override
            public void onNext(T t) {
                if (!isUnsubscribed()) {
                    subscriber.onNext(t);
                }
            }
        };
    }
});

如果稍后再调用observeOn()，则会出现问题，这将是异步的，显然我的异常处理将无法正常工作。

有没有办法实现这一目标。我希望会有一个subscribe()方法，它不会在OnErrorNotImplementedException中抛出onError。

最佳答案

这是我们在工作中的方法。我们没有执行任何操作，而是制作了一个抽象的NYTSubscriber，它实现了onError和onCompleted。这样，您可以使用此订户并仅实现onNext回调，或者可以在必要时覆盖onError和onCompleted

public abstract class NYTSubscriber<T> extends Subscriber<T> {

@Override
public void onCompleted() {
}

@Override
public void onError(Throwable e) {
}
}