RxSwift中合并多Observable及图片下载两类回调实现方案咨询

嘿，针对你提出的两个需求，RxSwift里有非常贴合的操作符可以实现，我来一步步给你说明：

需求1：每次下载完成时发送事件 #

如果想让新的Observable在每一张图片下载完成时就立刻发送结果，你可以用merge操作符。它能把多个Observable（这里是你的Single序列）合并成一个，只要其中任意一个Single完成并发射结果，合并后的Observable就会立刻把这个结果发出去。

代码示例：

// 先把所有图片下载的Single收集到一个数组里
let imageSingles: [Single<UIImage?>] = (0...N).map { _ in
    fetchImage(from: url)
}

// 把Single转成Observable，然后merge
let eachDownloadObservable = Observable.merge(imageSingles.map { $0.asObservable() })

// 订阅这个Observable，每次有图片下载完成就会收到事件
eachDownloadObservable.subscribe(onNext: { image in
    print("一张图片下载完成：\(image ?? UIImage())")
}, onError: { error in
    print("下载出错：\(error)")
}).disposed(by: disposeBag)

注意：如果其中任何一个Single发射了错误事件，merge后的Observable会立刻终止并发送错误。如果想让其他下载不受单个错误影响，可以给每个Single添加catchAndReturn或者catch操作符处理错误。

需求2：所有下载完成时发送完成事件 #

如果要等所有图片都下载完成后，一次性拿到所有结果，那forkJoin（或者针对Single的Single.zip）就是最佳选择。它会等待所有输入的Single都完成，然后把所有结果打包成一个数组发射出来，之后才会发送完成事件。

代码示例：

// 同样先收集所有Single
let imageSingles: [Single<UIImage?>] = (0...N).map { _ in
    fetchImage(from: url)
}

// 使用Single.zip合并（针对Single的forkJoin等价实现）
let allDownloadsCompletedObservable = Single.zip(imageSingles)

// 订阅这个Single，所有下载完成后会收到所有图片的数组
allDownloadsCompletedObservable.subscribe(onSuccess: { images in
    print("所有图片下载完成，共\(images.count)张")
    // 这里可以统一处理所有图片
}, onError: { error in
    print("其中某个下载出错：\(error)")
}).disposed(by: disposeBag)

补充：只要有一个Single发射错误，整个序列就会立刻终止并发送错误。如果需要容错，可以给每个Single添加错误处理，比如catchAndReturn(nil)，这样即使某个下载失败，也不会影响整体等待所有任务完成。

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