RxJava1 vs Rxjava2: 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中的错误吗？或者，这不是一次有意识的改变，因为我找不到关于这方面的任何细节？

ps。我确实注意到，将它包装到'SafeObserver‘中会重新路由到onError

Answer 1

没有错，两个版本有不同的设计约束。在2.x中，Observer/Subscriber不能从它的onXXX方法抛出。

如果您在2.x中使用1-2-3个参数的subscribe()方法，您将会被介绍。否则，如果你真的不能修复你的onNext，使用safeSubscribe()。