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;
            }
        });

如果您不关心发出值，也许您可​​以使用 Filter 运算符:

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

希望这有帮助。

抱歉我的英语不好。