Loop mit RxSwift

Question

Ich bin neu in Reactive Programming und ich habe ein großes Problem, das ich nicht allein lösen kann ... Ich muss mehrere Video-Assets hochladen und in einer geordneten Reihenfolge, aber ich weiß nicht, wie es geht ich eine Reihe von PHAssets habe und ich versuche, durch jedes Element zu durchlaufen und über das Netzwerk Hier ist mein Code mit Kommentaren bisher senden:

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

Wenn Sie Ihre Elemente nacheinander in flatMap hochladen, dann Aufzählung verwenden

EDIT: Aufzählung ist nützlich, wenn Sie den Index des Elements müssen wissen, sonst nur flatMap mit einem Argument tun wird.

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

Answer 2

beobachtbaren Stellen aus der Sammlung Elementen und .flatMap () sie zu Ihrem vorhandenen Code -

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