如何在 RxSwift 中组合多个 Observable

debugcn 发表于 Dev

13thang08

假设我为每个图像下载创建了一个 Observable

for _ in 0...N {
    let s : Single<UIImage?> = fetchImage(from url)
}

我怎样才能：

创建一个新的 Observable 以在下载完成时发出事件
创建一个新的 Observable 以在所有下载完成时仅发出完成的事件

谢谢！

克里斯威洛

创建一个新的 Observable 以在下载完成时发出事件

查看imageObservable可能实现的方法。

创建一个新的 Observable 以在所有下载完成时仅发出完成的事件

该zip（文档）运营商可能是你在找什么。

import RxSwift
import UIKit

enum CustomError: Error {
    case someError
}

class Executer {

    let disposeBag = DisposeBag()

    func execute() {
        let imageURLs = [
            URL(string: "http://via.placeholder.com/350x150")!, 
            URL(string: "http://via.placeholder.com/350x150")!
        ]
        let imageObservables = imageURLs.map { self.imageObservable(url: $0) }
        Observable
            .zip(imageObservables) // wait for all image requests to finish
            .subscribe(onNext: { images in
                // here you have every single image in the 'images' array
                images.forEach { print($0) }
            })
            .disposed(by: disposeBag)
     }

     // wrap 'URLSession' datatask into an observable
     func imageObservable(url: URL) -> Observable<UIImage> {
        return Observable.create { observer in
            URLSession
                .shared
                .dataTask(with: url, completionHandler: { (data, response, error) -> Void in
                    if let error = error {
                        observer.onError(error)
                        return
                    }
                    guard let data = data, let image = UIImage(data: data) else {
                        observer.onError(CustomError.someError)
                        return
                    }
                    observer.onNext(image)
                    observer.onCompleted()
                })
                .resume()
            return Disposables.create()
        }
    }
}

这个答案可能也与您有关。

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。