RxJava:如何包装多步骤操作，将完成的步骤返回给观察者？

Observable.create(new ObservableOnSubscribe<Integer>() {
    @Override
    public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
        // 第一步骤：执行一些操作，例如从网络获取数据
        int result = fetchDataFromNetwork();

        // 将结果发送给观察者
        emitter.onNext(result);
        emitter.onComplete();
    }
})
    .subscribeOn(Schedulers.io()) // 在IO线程执行
    .observeOn(AndroidSchedulers.mainThread()) // 在主线程观察结果
    .subscribe(new Observer<Integer>() {
        @Override
        public void onSubscribe(Disposable d) {
            // 可选的，可以在这里进行一些初始化操作
        }

        @Override
        public void onNext(Integer result) {
            // 第二步骤：处理结果，例如更新UI
            updateUI(result);
        }

        @Override
        public void onError(Throwable e) {
            // 发生错误时的处理逻辑
        }

        @Override
        public void onComplete() {
            // 所有步骤完成时的处理逻辑
        }
    });