使用RxSwift嵌套网络API时flatMap报表达式类型歧义错误求助

问题描述 #

使用RxSwift嵌套调用两个网络API时，flatMap持续提示「Type of expression is ambiguous without more context」错误。作为RxSwift新手，已花费近两天排查，尝试显式声明所有类型仍无法解决，不清楚编译器为何无法识别闭包的返回类型。

原代码如下：

private func uploadImage(imageUrl: URL) -> Observable<String> {
    do {
        let data = try Data(contentsOf: imageUrl)
        let fileExtension = imageUrl.pathExtension
        return Single<String>.create(subscribe: { single in
            AppManager.shared.dataAdapter.apiCallUploadDocument(data: data, fileExtension: fileExtension) { result in
                switch result {
                case .success(let documentId):
                    single(.success(documentId))
                case .failure(let error):
                    single(.failure(error))
                }
            }
            return Disposables.create()
        }).asObservable()
    } catch let error {
        return Observable.error(error)
    }
}

func subscribePlan(data: SCSubscribeData) -> Observable<PurchaseResponse> {
    let settings = AppManager.shared
    let idCardPhoto = data.idCardPhoto
    let governmentPassportPhoto = data.governmentPasspordIdPhoto
    let isUserProfileUpdated = settings.loginResult.profileUpdated
    if isUserProfileUpdated {
        let icDocumentType = settings.eligibilityInput.getSubscriberData()["idType"] ?? ""
        return uploadImage(imageUrl: idCardPhoto.url)
            .flatMap({ documentId in
                let param: [String: String] = [
                    "eligibilityDocument": documentId,
                    "icDocument": "EXISTED",
                    "icDocumentType": icDocumentType,
                    "eligibilityDocumentNo": data.idNumber,
                ]
                let scAdditionalParameter: [String : AnyObject] = [
                    "properties": param
                ]
                return subscribe(purchaseModel: data.purchaseModel, additionalParam: scAdditionalParameter)
            })
        
    }
    return Observable<PurchaseResponse>.error(NSError())
}

func subscribe(purchaseModel: PurchaseModel, additionalParam: [String: AnyObject]) -> Observable<PurchaseResponse> {
    return Single.create(subscribe: { single in
        AppManager.shared.dataAdapter.apiCallPurchaseSubscription(purchaseModel: purchaseModel,
                                                         additionalParameter: additionalParam,
                                                         result: { result in
            switch result {
            case .success(let res):
                single(.success(res))
            case .failure(let error):
                single(.failure(error))
            }
        })
        return Disposables.create()
    }).asObservable()
}

问题原因 #

1. 字典类型桥接干扰推导：scAdditionalParameter使用[String: AnyObject]类型，而param是[String: String]（值类型），隐式桥接为AnyObject会让编译器无法清晰推导闭包返回值的类型。
2. flatMap泛型未明确：未显式指定flatMap的泛型参数，编译器无法直接关联上游Observable<String>和下游Observable<PurchaseResponse>的类型关系。

解决方案 #

修改步骤： #

1. 将所有[String: AnyObject]替换为[String: Any]，符合Swift现代语法，避免不必要的OC桥接。
2. 给flatMap显式指定输入输出类型，帮助编译器明确类型关系。
3. 优化错误返回，创建带具体信息的NSError而非空实例。

修改后的代码： #

private func uploadImage(imageUrl: URL) -> Observable<String> {
    do {
        let data = try Data(contentsOf: imageUrl)
        let fileExtension = imageUrl.pathExtension
        return Single<String>.create(subscribe: { single in
            AppManager.shared.dataAdapter.apiCallUploadDocument(data: data, fileExtension: fileExtension) { result in
                switch result {
                case .success(let documentId):
                    single(.success(documentId))
                case .failure(let error):
                    single(.failure(error))
                }
            }
            return Disposables.create()
        }).asObservable()
    } catch let error {
        return Observable.error(error)
    }
}

func subscribePlan(data: SCSubscribeData) -> Observable<PurchaseResponse> {
    let settings = AppManager.shared
    let idCardPhoto = data.idCardPhoto
    let governmentPassportPhoto = data.governmentPasspordIdPhoto
    let isUserProfileUpdated = settings.loginResult.profileUpdated
    
    if isUserProfileUpdated {
        let icDocumentType = settings.eligibilityInput.getSubscriberData()["idType"] ?? ""
        return uploadImage(imageUrl: idCardPhoto.url)
            // 显式指定flatMap的输入输出类型
            .flatMap { (documentId: String) -> Observable<PurchaseResponse> in
                let param: [String: String] = [
                    "eligibilityDocument": documentId,
                    "icDocument": "EXISTED",
                    "icDocumentType": icDocumentType,
                    "eligibilityDocumentNo": data.idNumber,
                ]
                // 改用[String: Any]替代AnyObject
                let scAdditionalParameter: [String: Any] = [
                    "properties": param
                ]
                return self.subscribe(purchaseModel: data.purchaseModel, additionalParam: scAdditionalParameter)
            }
    }
    
    // 返回带具体信息的错误
    let error = NSError(domain: "SubscribePlanError", code: -1, userInfo: [NSLocalizedDescriptionKey: "用户资料未更新"])
    return Observable<PurchaseResponse>.error(error)
}

// 调整参数类型为[String: Any]
func subscribe(purchaseModel: PurchaseModel, additionalParam: [String: Any]) -> Observable<PurchaseResponse> {
    return Single.create(subscribe: { single in
        AppManager.shared.dataAdapter.apiCallPurchaseSubscription(purchaseModel: purchaseModel,
                                                                 additionalParameter: additionalParam as? [String: AnyObject], // 如果API要求AnyObject，这里显式转换
                                                                 result: { result in
            switch result {
            case .success(let res):
                single(.success(res))
            case .failure(let error):
                single(.failure(error))
            }
        })
        return Disposables.create()
    }).asObservable()
}

额外说明 #

• 如果apiCallPurchaseSubscription方法的additionalParameter参数必须是[String: AnyObject]，可以在调用时显式转换：additionalParam as? [String: AnyObject]，但优先建议API层适配[String: Any]。
• RxSwift中尽量避免隐式类型转换，显式声明泛型参数和变量类型能大幅减少编译器歧义问题。

内容的提问来源于stack exchange，提问作者code4food