如何使用 RxSwift 将两个 observable 合并到另一个 observable？

Question

如何使用 RxSwift 将两个 observable 合并到另一个 observable？ 就我而言：

struct ViewModel {

let items: Observable<[MediaAsset]>

init(type: Observable<AssetMediaType>, provider: DataProvider) {
    items = Observable.combineLatest(type, provider.rx.didAuthorize, resultSelector: { (type, status)  in
        return provider.rx.fetchMedia(type)
    })
}

public var didAuthorize: Observable<AuthorizeResult> {
    return Observable.create { o in
       //....
    }
}

public func fetchMedia(_ withType: AssetMediaType) -> Observable<[MediaAsset]> {
    return Observable.create { observer in
       //....
    }
}

但是 xcode 构建失败的原因：

无法将类型 '(AssetMediaType, ) -> Observable' 的值转换为预期的参数类型 '(, _) -> _'

Answer 1

根本问题：

您的类型不匹配。

假设那些函数属于DataProvider.rx，而不是ViewModel，这段代码：

Observable.combineLatest(type, provider.rx.didAuthorize, resultSelector: { (type, status)  in
    return provider.rx.fetchMedia(type)
})

返回一个 Observable>

但您将项目声明为 Observable

解决方案：将 observable 展平

items = Observable.combineLatest(type, provider.didAuthorize) { type,status in
        return (type,status)
    }
    .flatMapLatest { type,status in
        return provider.fetchMedia(type)
            
    }

注意：目前尚不清楚您是如何使用状态的。我把它传给了 flatMapLatest，但它不会再传下去了。

Answer 2

如果您希望它们同时触发，则需要使用 Zip

let zipped = Observalbe.zip(a, b){$0}

或在您的代码中

struct ViewModel {

let items: Observable<[MediaAsset]>

init(type: Observable<AssetMediaType>, provider: DataProvider) {
    items = Observable.zip(type, provider.rx.didAuthorize){$0}

}