防止OnErrorNotImplementedException

Prevent OnErrorNotImplementedException(防止OnErrorNotImplementedException)

本文介绍了防止OnErrorNotImplementedException的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我想实现的是,如果我调用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的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本文标题为:防止OnErrorNotImplementedException

基础教程推荐