前言
在之前的文章Moya+PromiseKit+RxSwift优雅的书写网络请求中，我们尝试了使用PromiseKit和RxSwift共同实现网络请求，在后来我个人的尝试中发现了问题，遂撰文记之。
问题描述
PromiseKit的闭包只会执行一次。
环境配置
- Xcode 8.3
- Swift 3
实例
这一切都是由于实现一个带有缓存的网络请求引起的。为此我们实现一个RxMoyaProvider的Extension，用于实现带有缓存的网络请求。
extension RxMoyaProvider {
func offLineCacheRequest(_ token: Target) -> Observable<Response> {
return Observable.create({[weak self] (observer) -> Disposable in
// 1. 在这里我们读取本地缓存中的数据，若有缓存，则返回缓存数据
// 伪代码
if 存在缓存 {
observer.onNext(缓存数据)
}
//2 .进行正常的网络请求
let cancellableToken = self?.request(token) { result in
switch result {
case let .success(response):
// 3. 返回请求后的最新数据
observer.onNext(response)
observer.onCompleted()
// 4. 缓存并覆盖旧数据
// 伪代码
缓存数据
case let .failure(error):
observer.onError(error)
}
}
return Disposables.create {
cancellableToken?.cancel()
}
})
}
}
我们基于刚刚实现的这个拓展再实现一个网络请求。注意此处成功的回调result。
func getHomepagePageDataWithCache() -> Promise<HomepageData> {
return Promise(resolvers: { (result, error) in
provider.offLineCacheRequest(.frontpage)
.distinctUntilChanged()
.filterSuccessfulStatusCodes()
.mapJSON()
.mapObject(type: HomepageData.self)
.subscribe(onNext: {
result($0) //此处为PromiseKit的成功回调
}, onError: {
error($0)
})
.addDisposableTo(disposeBag)
})
}
然鹅就在这里出现问题了，当我们调用这个方法时：
viewModel.getHomepagePageDataWithCache().then {
print($0.packages?.last?.head ?? "")
}.catch {
print($0)
}
第一次调用因为本地没有缓存，所以打印print($0.packages?.last?.head ?? "")只会调用一次，然鹅再次运行，存在本地缓存的情况下，该打印语句依然只执行一次。
经过打断点，我发现相关代码均已经执行：
// 请求成功前
if 存在缓存 {
observer.onNext(缓存数据)
}
// 请求成功后
observer.onNext(response)
以上两次 observer.onNext都触发了RxSwift订阅，断点也会停留在订阅里面PromiseKit的闭包result上：
.subscribe(onNext: {
result($0)
},
但是在最终的闭包里只执行了一次打印：
then {
print($0.packages?.last?.head ?? "")
}.
原因
经过查询资料，原因如下：
PromiseKit 不具备流的特性，即不支持依赖时间顺序依次传递值，换句话说就是调用闭包 result多次也只能执行一次。这就没办法让我们以完整的声明式的写法完成需求。
所以要想两次都触发并执行RxSwift的订阅，就不能使用PromiseKit来实现这个网络请求。处理很简单，就是把PromiseKit里面实现网络请求的部分提出来改写即可。
provider.offLineCacheRequest(.frontpage)
.distinctUntilChanged()
.filterSuccessfulStatusCodes()
.mapJSON()
.mapObject(type: HomepageData.self)
我们把这个mapObject后的Observable返回即可，让后续的操作订阅它。
