我有两种这样的方法:
func rxGetAllTonicsForLanguage(language: Language) -> Observable<AnyObject?>
func saveTonics(list: [Tonic]) -> Observable<AnyObject?>
现在我想先执行 getAllTonics 调用,然后根据该调用的结果执行下一个操作。所以我认为这是我可以用 FlatMap 做的事情。但我被困住了,我不知道如何链接这些。
我试过如下:
self.remoteService.rxGetAllTonicsForLanguage(language)
.subscribeOn(ConcurrentDispatchQueueScheduler(globalConcurrentQueueQOS: .Background))
.flatMap{tonics -> Observable<[Tonic]> in
print("Tonics: \(tonics)")
let x = tonics as! [Tonic]
return TonicAdapter.sharedInstance.saveTonics(x)
}.observeOn(MainScheduler.instance)
.subscribe({ e in
switch e {
case .Next(let element):
if let result = element as? String {
DDLogDebug("Saved something \(result)")
}
case .Error(let e):
DDLogError("Error in save tonics \(e)")
case .Completed:
DDLogDebug("Completed save tonics")
}
}
).addDisposableTo(self.disposeBag)
它在返回 TonicAdapter 的行上给我这个错误:
Cannot convert return expression of type 'Observable<AnyObject?>' (aka 'Observable<Optional<AnyObject>>') to return type 'Observable<[Tonic]>' (aka 'Observable<Array<Tonic>>')
我没有看到问题,因为这两种方法都返回 Observables?
最佳答案
您需要将 saveTonics 中声明的返回类型从 Observable 更改为 Observable<[Tonic]>。或者您可以进行相同的更改(如果您确定情况总是如此)。
关于ios - RXSwift flatMap 两种方法,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38252111/