结合管道从压缩发布者下载图像

Question

我在函数中压缩了两个发布者，通过后端 API 下载用户和车辆：

   func fetchUserAndvehicles() {
       Publishers.Zip(UserApiClient().getUser(), VehicleApiClient().getVehicles())
           .eraseToAnyPublisher()
           .receive(on: DispatchQueue.main)
           .sink(receiveCompletion: { [weak self] completion in
               switch completion {
               case .failure(let error):
                   self?.errorHandling.showErrorAlert(error)
               case .finished:
                   break
               }
               }, receiveValue: { [weak self] user, vehicles in
                   // store vehicles in the user object
           })
           .store(in: &subscriptions)
   }

每辆车都有一个imageUrl，可用于下载车辆的图像。这工作正常。但是我想在将车辆存储在用户对象中之前下载图像（如果有的话）。是否可以使用相同的组合管道来执行此操作？我尝试使用flatMap，但导致编译错误。

以下内容来自 Cristik 的出色回答。看起来没问题，但是 Xcode 用 No exact matches in call to instance method 'flatMap' 标记了 flatMap 行：

let vehiclesPublisher = VehicleApiClient().getVehicles()
    .flatMap { vehicles in
        Publishers.Zip(Just(vehicles).setFailureType(to: Error.self), Publishers.MergeMany(vehicles.map { VehicleApiClient().getImage(at: $0.url)}).collect())
    }
    .map {
        return $0.0
    }

车辆有一个可选属性需要解包，但这不是编译错误的原因。

Answer 1

你需要做的是

1. 将车辆发布者转换为图像下载发布者数组
2. Create a single publisher from a list of publishers
3. 等待那个发布者

假设你在某处有一个downloadImage(from url: URL) 函数，并且你的Vehicle 类型有一个imageURL 属性，那么为了完成你所需要的，你必须做的是

let vehiclesPublisher = VehicleApiClient().getVehicles()
    .flatMap { vehicles in
        Publishers.Zip(Just(vehicles).setFailureType(to: Error.self), // setFailureType dance needed
                       Publishers.MergeMany(vehicles.map { downloadImage(from: $0.imageURL) }).collect())
    }.map {
        return $0.0 // unpack the vehicles, so we have back a publisher that outputs [Vehicle]
    }

Publishers.Zip(UserApiClient().getUser(), vehiclesPublisher)
    // rest of the pipeline stays the same

在上面的代码中发生的事情是，我们将车辆数组转换为图像下载器数组，由 collect() 运算符等待。但是我们还需要保留vehicles数组，所以需要一个zip，然后解压zip返回的第一个项目，因为我们不关心图片下载状态，我们只关心所有他们完成。