如何用RxSwift实现递归分页网络调用

import RxSwift
import RxCocoa

func recursivePageRequest(page: Int) -> Observable<[Data]> {
    return Observable.create { observer in
        // 发起网络请求，获取第page页的数据
        YourNetworkingLibrary.requestData(page: page) { result in
            switch result {
            case .success(let data):
                // 处理返回的数据
                observer.onNext(data)
                
                // 判断是否还有下一页数据需要请求
                if hasMorePages(data) {
                    // 递归调用自身，请求下一页数据
                    recursivePageRequest(page: page + 1)
                        .subscribe(onNext: { nextPageData in
                            // 合并上一次请求的数据和当前请求的数据
                            observer.onNext(nextPageData)
                        }, onError: { error in
                            observer.onError(error)
                        }, onCompleted: {
                            observer.onCompleted()
                        })
                        .disposed(by: disposeBag)
                } else {
                    // 已经请求到了最后一页数据，结束递归调用
                    observer.onCompleted()
                }
                
            case .failure(let error):
                observer.onError(error)
            }
        }
        
        return Disposables.create()
    }
}

// 使用示例
recursivePageRequest(page: 1)
    .subscribe(onNext: { data in
        // 处理最终的数据
    }, onError: { error in
        // 处理错误
    }, onCompleted: {
        // 请求结束
    })
    .disposed(by: disposeBag)