RxJava +改装失败时返回自定义异常

Observable.just(data)
    .map(result -> {
        // 进行改装操作
        if (isFailed(result)) {
            throw new CustomException("改装失败");
        }
        return result;
    })
    .onErrorReturn(throwable -> {
        if (throwable instanceof CustomException) {
            return handleCustomException((CustomException) throwable);
        } else {
            return handleOtherException(throwable);
        }
    })
    .subscribe(new Observer<Result>() {
        @Override
        public void onSubscribe(Disposable d) {
            // 订阅时的操作
        }

        @Override
        public void onNext(Result result) {
            // 处理成功的结果
        }

        @Override
        public void onError(Throwable e) {
            // 处理异常情况
        }

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