12

我想实现，如果我调用该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()方法不会扔进OnErrorNotImplementedException去onError。

4

5 回答 5

16

这是另一种可能的解决方案，您可以定义 onNext 和 Throwable （您也不能放弃 lambda 语法）：

.subscribe(t -> doSomething(t), e -> showError(e));
于 2016-05-30T14:15:20.090 回答
10

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

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

@Override
public void onCompleted() {
}

@Override
public void onError(Throwable e) {
}
}
于 2015-11-05T16:32:06.273 回答
5

如果您使用的是Kotlin，那么语法就像

 .subscribe({success -> doOnSuccess(success)},{error -> doOnError(error)})
于 2019-11-26T09:57:30.803 回答
0

调用 Subscribe 方法时出现此错误，但未提供 onError() 回调。 科特林

subscribe(object : DisposableCompletableObserver() {
    override fun onComplete() {
        // on successful completion   }
    override fun onError(e: Throwable) {
        //error message
    }
    }
  )
于 2020-03-19T16:53:12.910 回答
0

当你喜欢这个 '.onErrorResumeNext(Observable.empty())' 时，你的流将在发生错误时完成——这就是你的操作永远不会被调用的原因。您可以使用“.retry()”，当您遇到错误时，您的流将自动重新启动。

于 2017-08-09T08:30:40.537 回答