Combine新手求助：无法将AnyPublisher<T, any Error>转为AnyPublisher<T, ServiceError>

我是Combine新手，创建了一个泛型函数，期望返回包含结果（T）和自定义错误（ServiceError）的AnyPublisher<T, ServiceError>。通过URLSession的dataTaskPublisher发起请求时，遇到如下错误：

Cannot convert return expression of type 'AnyPublisher<T, any Error>' to return type 'AnyPublisher<T, ServiceError>'

相关代码 #

URLRequest扩展代码 #

extension URLRequest {
    static func getRequest(client: ServiceClient) -> URLRequest? {
        guard var urlComponents = URLComponents(string: client.baseUrl + client.path) else {
            return nil
        }
        urlComponents.query = "\(client.params)"
        guard let url = urlComponents.url else {
            return nil
        }
        var urlRequest = URLRequest(url: url)
        urlRequest.httpMethod = client.method
        return urlRequest
    }
}

核心实现代码 #

class ServiceImpl: Service {

    let urlSession = URLSession(configuration: .default)
    var dataTask: URLSessionDataTask?

    func fetchData<T: Codable>(client: ServiceClient, type: T.Type) -> AnyPublisher<T, ServiceError> {

        guard let request = URLRequest.getRequest(client: client) else {
            return Fail(outputType: type, failure: ServiceError.requestNotCreated(message: Constants.requestNotCreated)).eraseToAnyPublisher()
        }
        return urlSession.dataTaskPublisher(for: request)
            .tryMap {
                guard let response = $0.response as? HTTPURLResponse, response.statusCode == 200 else {
                    throw ServiceError.errorWith(message: Constants.noResponse)
                }
                return $0.data
            }
            .decode(type: T.self, decoder: JSONDecoder())
            .receive(on: RunLoop.main)
            .eraseToAnyPublisher()
    }
}

错误截图 #

解决方案 #

问题出在tryMap和decode操作符会抛出任意Error类型，导致最终的Publisher错误类型变成any Error，和函数声明的ServiceError不匹配。需要用mapError操作符将所有错误统一转换为自定义的ServiceError。

修改后的fetchData函数如下：

func fetchData<T: Codable>(client: ServiceClient, type: T.Type) -> AnyPublisher<T, ServiceError> {

    guard let request = URLRequest.getRequest(client: client) else {
        return Fail(outputType: type, failure: ServiceError.requestNotCreated(message: Constants.requestNotCreated)).eraseToAnyPublisher()
    }
    return urlSession.dataTaskPublisher(for: request)
        .tryMap {
            guard let response = $0.response as? HTTPURLResponse, response.statusCode == 200 else {
                throw ServiceError.errorWith(message: Constants.noResponse)
            }
            return $0.data
        }
        .decode(type: T.self, decoder: JSONDecoder())
        .receive(on: RunLoop.main)
        .mapError { error -> ServiceError in
            // 区分不同错误类型，转换为自定义错误
            if let serviceError = error as? ServiceError {
                return serviceError
            } else if error is DecodingError {
                return ServiceError.decodingFailed(message: Constants.decodingError)
            } else {
                // 处理其他网络相关错误
                return ServiceError.networkError(message: Constants.networkError)
            }
        }
        .eraseToAnyPublisher()
}

说明 #

• mapError操作符会捕获上游所有类型的Error，将其转换为ServiceError，确保Publisher的错误类型和函数返回值一致。
• 根据实际业务需求，可以扩展ServiceError的枚举case，覆盖更多错误场景（比如解码失败、网络异常等）。

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