ReactiveKit:观察一组信号，当它们全部完成时执行某些操作

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")
    }
})