使用 RxSwift 循环

Question

我是响应式编程的新手，我有一个无法单独解决的大问题...我需要按顺序上传几个视频资产，但我不知道该怎么做，我有一组PHAssets，我正在尝试遍历每个元素并通过网络发送它 到目前为止，这是我使用 cmets 的代码：

for item in items {
                    let fileName = item.media.localIdentifier

                    //Observable to generate local url to be used to save the compressed video
                    let compressedVideoOutputUrl = videoHelper.getDocumentsURL().appendingPathComponent(fileName)

                    //Observable to generate a thumbnail image for the video
                    let thumbnailObservable =  videoHelper.getBase64Thumbnail(myItem: item)

                    //Observable to request the video from the iPhone library
                    let videoObservable = videoHelper.requestVideo(myItem: item)

                        //Compress the video and save it on the previously generated local url
                        .flatMap { videoHelper.compressVideo(inputURL: $0, outputURL: compressedVideoOutputUrl) }
                    //Generate the thumbnail and share the video to send over the network
                    let send = videoObservable.flatMap { _ in thumbnailObservable }
                        .flatMap { api.uploadSharedFiles(item, filename: fileName, base64String: $0) }

                    //subscribe the observable
                    send.subscribe(onNext: { data in
                        print("- Done chain sharing Video -")
                    },
                                   onError: { error in
                                    print("Error sharing Video-> \(error.localizedDescription)")
                    }).disposed(by: actionDisposeBag)

                }

Answer 1

如果你想在flatMap中一个一个地上传你的物品，那么使用枚举

编辑：枚举在您需要知道元素的索引时很有用，否则只需 flatMap 和一个参数即可。

Observable.from(items)
    .enumerated()
    .flatMap() { index, item -> Observable<Item> in
        return uploadItem(item)
    }
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)

Answer 2

将集合元素和 .flatMap() 变成可观察到您现有的代码 -

Observable
  .from(items)
  .flatMap { (item) -> Any in
    // your code
      return send
  }
  .subscribe( /* your code */ )
  .disposed(by: actionDisposeBag)