【发布时间】:2016-08-25 07:00:52
【问题描述】:
我在看那两个:
- http://sapandiwakar.in/refresh-oauth-tokens-using-moya-rxswift/
- Using retryWhen to update tokens based on http error code
并尝试使用 Alamofire + RxSwift 创建类似的东西,但没有 Moya。
首先显然我应该把它放在哪里,因为我的实现分为几个较小的部分。 首先,我有生成 reactive 请求的自定义方法:
static func rx_request<T>(requestConvertible: URLRequestConvertible, completion: (Request) -> Observable<T> ) -> Observable<T> {
let manager: Manager = Manager.sharedInstance
return manager
.rx_request { manager -> Request in
return Alamofire.request(requestConvertible)
}
.flatMap { request -> Observable<T> in
return completion(request)
}
.shareReplay(1)
}
稍后被特定的Requests 便利类使用。例如我的UserRequests 有这个私有扩展来从它的方法中提取一些通用代码:
private extension Request {
func rx_userRequest() -> Observable<User> {
return self
.validate()
.rx_responseJSON()
.flatMap{ (request, json) -> Observable<User> in
guard
let dict = json as? [ String: AnyObject ],
let parsedUser: User = try? Unbox(dict) else {
return Observable.error(RequestError.ParsingError)
}
return Observable.just(parsedUser)
}
.rx_storeCredentials()
}
}
因为事情看起来像我想知道放置retry 方法的正确位置是什么以及如何实现它?因为根据位置,我可以获得不同的输入参数。
【问题讨论】:
标签: swift alamofire rx-swift reactivex