问题描述

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

.onErrorResumeNext(Observable.empty())

这种方式OnErrorNotImplementedException不会引发，但是如果我同时传递第二个操作，则也永远不会调用该操作。

第二：

.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()方法不会在onError中引发OnErrorNotImplementedException。

推荐答案

我们在工作中是这样做的。我们没有执行操作，而是创建了一个抽象的NYTSubscriber，它实现了onError和onComplete。这样，您可以使用此订阅服务器，并且只实现onNext回调，或者在必要时重写onError和onComplete

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

@Override
public void onCompleted() {
}

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

这篇关于防止OnErrorNotImplementedException的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！