反应工具包:观察一系列信号，当它们全部完成时做一些事情

Question

我对响应式编程很陌生，并且在我的应用程序中使用带有ReactiveKit的Bond。我现在遇到了一个我无法完全弄清楚的问题。

问题是在某个页面上我必须上传一些图像，当所有图像都上传时，我想做点什么。

这是我到目前为止的代码：

func uploadImages(completionHandler: @escaping EmptyBlock) {
let datas = profileImages.value.compactMap { $0?.jpegData(compressionQuality: 0.6) }
let signals = datas.map { data in
return Signal<String, Error> { observer in
self.user.uploadImage(data: data) { result in
switch result {
case .success(let url):
observer.receive(url)
observer.receive(completion: .finished)
case .failure(let error):
observer.receive(completion: .failure(error))
}
}
return SimpleDisposable(isDisposed: false)
}
}
// What can I do with `signals`?
}

所以我有一个属性profileImages，它是一个UIImage数组的可观察量。执行uploadImages时，我想使用函数user.uploadImage上传所有图像，当所有上传完成后，我想调用uploadImages函数的completionHandler。

在这一点上，我有一个信号数组，但我无法弄清楚如何观察所有这些信号，或者将它们组合成一个信号的方法？

Answer 1

我认为如果你稍微分解一下函数会对你有所帮助：

extension User {
func uploadImage(data: Data) -> Signal<String, Error> {
return Signal { observer in
self.uploadImage(data: data) { result in
switch result {
case .success(let url):
observer.receive(url)
observer.receive(completion: .finished)
case .failure(let error):
observer.receive(completion: .failure(error))
}
}
return SimpleDisposable(isDisposed: false)
}
}
}

以上内容会将单个上传包装在信号中。然后，您可以：

let user = self.user! // this is to avoid capturing `self` inside the map below.
let urlSignals = profileImages.value
.compactMap { $0?.jpegData(compressionQuality: 0.6) }
.map { user.uploadImage(data: $0) }
let urls = Signal(combiningLatest: urlSignals, combine: { $0 })
disposeBag += urls.observe(with: { event in
switch event {
case .next(let urls):
print("all urls:", urls)
case .failed(let error):
print("an upload failed:", error.localizedDescription)
case .completed:
print("upload complete")
}
})