android - 使用 RxJava2 和普通空响应错误改造 2

Question

我使用 RxJava2 extension with Retrofit .

RxJava2 观察者不支持在 onNext 函数中省略 null。

当我调用带有错误输入的 web 服务或 web 服务上出现任何错误时，我得到简单的 null 作为响应。

我认为，然后作为 null 传递给 rx2 observable。

这是我得到的错误:

java.lang.NullPointerException: Null is not a valid element
        at io.reactivex.internal.queue.SpscLinkedArrayQueue.offer(SpscLinkedArrayQueue.java:68)
        at io.reactivex.internal.operators.observable.ObservableObserveOn$ObserveOnObserver.onNext(ObservableObserveOn.java:116)
        at io.reactivex.internal.operators.observable.ObservableSubscribeOn$SubscribeOnObserver.onNext(ObservableSubscribeOn.java:63)
        at retrofit2.adapter.rxjava2.BodyObservable$BodyObserver.onNext(BodyObservable.java:51)
        at retrofit2.adapter.rxjava2.BodyObservable$BodyObserver.onNext(BodyObservable.java:37)
        at retrofit2.adapter.rxjava2.CallExecuteObservable.subscribeActual(CallExecuteObservable.java:43)
        at io.reactivex.Observable.subscribe(Observable.java:10179)
        at retrofit2.adapter.rxjava2.BodyObservable.subscribeActual(BodyObservable.java:34)
        at io.reactivex.Observable.subscribe(Observable.java:10179)
        at io.reactivex.internal.operators.observable.ObservableSubscribeOn$1.run(ObservableSubscribeOn.java:39)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:423)
        at java.util.concurrent.FutureTask.run(FutureTask.java:237)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:154)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:269)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1113)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:588)
        at java.lang.Thread.run(Thread.java:818)

如何解决此类问题的发生？

Answer 1

您可以使用 Completable 代替 Observable，它不允许响应请求。

编辑:

也许你可以使用 Map运算符检查值是否为 null，并在这种情况下发送默认值。

Observable<MyClass> observable = myRetrofitService().map(new Function<MyClass, MyClass>() {
            @Override public MyClass apply(MyClass o) throws Exception {
                if (o == null) {
                    return defaultO;
                }
                return o;
            }
        });

如果你不关心发出一个值，也许你可以使用过滤器运算符:

Observable<MyClass> observable = myRetrofitService().filter(new Predicate<MyClass>() {
            @Override public boolean test(MyClass o) throws Exception {
                return o != null;
            }
        });

希望这对您有所帮助。

对不起我的英语。