需求背景:
进入界面后先定位获取一个定位地址 A,然后接口获取其它地址 [B, C, D],需要将定位地址 A 和接口获取的地址 [B, C, D],综合判断得到一个地址 Address 展示。
ViewModel 代码
// 获取到定位地址
let didGetUserLocation: BehaviorRelay<String?> = .init(value: nil)
// 获取到其它地址
let didGetOtherAddress: BehaviorRelay<String?> = .init(value: nil)
extension JLViewModel {
struct Input {
}
struct Output {
let address: BehaviorRelay<String>
}
func transform(input: Input) -> Output {
// 定位
self.locateAction()
// 接口获取其它地址
self.getOtherAddress()
// 定位城市和从详情识别综合判断得到的地址
let locationZipObs = Observable.zip(didGetUserLocation.skip(1), didGetOtherAddress.skip(1))
return Output.init(address: locationZipObs)
}
}
extension JLViewModel {
func locateAction() {
didGetUserLocation.accept("")
}
func getOtherAddress() {
didGetOtherAddress.accept("")
}
}
备注:
Observable.zip(didGetUserLocation.skip(1), didGetOtherAddress.skip(1)):
由于didGetUserLocation,?didGetOtherAddress 都是BehaviorRelay 类型, 需要skip(1)将第一次发送的默认值 skip
ViewController 代码
let output = viewModel.transform(input: input)
output.address.bind {[weak self](tuple) in
guard let weakSelf = self else {return}
// ....
}.disposed(by: rx.disposeBag)
存在的问题:
由于定位地址有缓存可以立即执行,而接口获取其它地址会有时延,所以执行顺序是:
1:定位 didGetUserLocation.accept("")
2:? viewController 中 output.transform
3:? viewController 中 output.address 被订阅 subscribe
4:接口获取其它地址 didGetOtherAddress.accept("")
定位在?output.address 被订阅 subscribe之前发送执行,不会被监听到,接口获取其它地址在subscribe 之后,会被监听到。而 RxSwift 关键词 zip 需要两个Observable 都有值才发送元素。
解决方案:
将?self.locateAction() ? ? self.getOtherAddress() 两个方法延时执行,保证didGetUserLocation, didGetOtherAddress?两个序列都在?output.address 被订阅 subscribe之后执行
DispatchQueue.main.asyncAfter(deadline: DispatchTime.now() + 0.3, execute: {
// 定位
self.locateAction()
// 接口获取其它地址
self.getOtherAddress()
})
|