ios - 使用响应式编程将具有 imageURL 的对象转换为具有下载的 UIImage 的对象

Question

我有一个 A 对象数组。我想将其转换为包含 B 类型对象的数组。但棘手的部分是同时下载图像并使用 RxSwift 或 ReactiveSwift 完成所有操作。你有什么建议我该怎么做吗？

struct A {
  let name: String
  let imageURL: URL
  let thumbnailURL: URL
}

struct B {
  let name: String
  let image: UIImage?
  let thumbnail: UIImage?
}

Answer 1

因此，尽管我对这可能非常重要的上下文进行了评论，但以下是我如何使用 ReactiveSwift 将 [A] 异步转换为 [B]。请注意，我还没有机会测试这段代码，但它应该涵盖基本思想:

// This function takes an `NSURL` and creates an asynchronous `SignalProducer` to
// download an image from that URL or yields `nil` if there is an error.
func downloadImage(url: URL) -> SignalProducer<UIImage?, NoError> {
    let request = URLRequest(url: url)
    return URLSession.shared.reactive.data(with: request)
        .map { (data, response) -> UIImage? in UIImage(data: data) }
        .flatMapError { _ in SignalProducer<UIImage?, NoError>(value: nil) }
}

func convertAToB(_ a: A) -> SignalProducer<B, NoError> {
    let imgDownload = downloadImage(url: a.imageURL)
    let thumbDownload = downloadImage(url: a.thumbnailURL)
    return SignalProducer<UIImage?, NoError>.combineLatest(imgDownload, thumbDownload)
        .map { images in
            return B(name: a.name, image: images.0, thumbnail: images.1)
        }
}

func convertAllAsToBs(_ inputs: [A]) -> SignalProducer<[B], NoError> {
    return SignalProducer<A, NoError>(values: inputs)
        .flatMap(.concat, convertAToB)
        .collect()
}


let inputs: [A] = ...

convertAllAsToBs(inputs).startWithValues { outputs in
    // `outputs` is [B]
}

编辑:

为了使这个答案与 @PhilippeC 的 RxSwift 答案相同，这里总结了每个 ReactiveSwift 运算符所做的事情:

• SignalProducer.init(values:) 相当于 RxSwift 的 Observable.from。它创建一个生产者，将序列的每个值作为单独的事件发送。
• collect 相当于 RxSwift 的 toArray。它从源生产者收集每个值，并在源生产者完成后将它们发送到单个数组中。
• flatMap 为每个传入的 A 启动 convertAToB 生产者，并根据指定的 FlattenStrategy 合并结果。在本例中，我使用了 .concat，这使其相当于 RxSwift 的 concatMap，它连接每个结果并保留 @PhilippeC 在其答案中描述的顺序。