rx-java - RxJava1 与 Rxjava2 : Exception in onNext

Question

在 RxJava1 中执行以下操作时，onNext 中的异常将被重新路由到同一个订阅者的 onError 中:

    Observable.from(Arrays.asList("1", "22", "333", "4444")).subscribe(new Subscriber<String>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {
            Log.d("RxJava1", "onError: " + e.getCause());
        }

        @Override
        public void onNext(String s) {
            if (s.length() == 4) {
                Integer test = null;
                test.hashCode();
            }
            Log.d("RxJava1", s + " - " + s.length());
        }
    });

输出:

D/RxJava1: 1 - 1
D/RxJava1: 22 - 2
D/RxJava1: 333 - 3
D/RxJava1: onError: null

这样做时，据我所知，在 RxJava2 中也是如此，这种行为发生了变化，不再返回 onError，而只是崩溃:

    Observable.fromIterable(Arrays.asList("1", "22", "333", "4444")).subscribeWith(new Observer<String>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onNext(String s) {
            if (s.length() == 4) {
                Integer test = null;
                test.hashCode();
            }
            Log.d("RxJava2", s + " - " + s.length());
        }

        @Override
        public void onError(Throwable e) {
            Log.d("RxJava2", "onError: " + e.getCause());
        }

        @Override
        public void onComplete() {

        }
    });

输出:

D/RxJava2: 1 - 1
D/RxJava2: 22 - 2
D/RxJava2: 333 - 3
D/AndroidRuntime: Shutting down VM

我最想知道，这两个版本中的哪一个是“错误的”？
这是 RxJava1 中已修复的错误吗？这是 RxJava2 中的错误吗？
或者这不是一个有意识的改变，因为我找不到任何关于这个的细节？

附:我确实注意到将其包装到“SafeObserver”中再次重新路由到 onError

Answer 1

两者都没有错，两个版本具有不同的设计约束。在 2.x 中 Observer/Subscriber不能扔掉它的onXXX方法。

如果您使用 1-2-3 参数 subscribe()涵盖了 2.x 中的方法。否则如果你真的无法修复你的 onNext使用 safeSubscribe() .