如何使用RxJava/RxAndroid在OnNext中抛出异常

Observable.just("Hello")
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 订阅时的操作
            }

            @Override
            public void onNext(String s) {
                // 处理事件的逻辑
                if (s.equals("Hello")) {
                    throw new RuntimeException("Something went wrong");
                }
            }

            @Override
            public void onError(Throwable e) {
                // 发生异常时的处理
                Log.e(TAG, "onError: " + e.getMessage());
            }

            @Override
            public void onComplete() {
                // 完成时的操作
            }
        });