使用 RxSwift 3.6.1,我对 ObservableType 进行了此扩展,以在错误请求后获取新令牌:
public extension ObservableType where E == Response {
public func retryWithToken() -> Observable<E> {
return retryWhen { error -> Observable<Response> in
return error.flatMap({ (error) -> Observable<Response> in
if let myApiError: MyApiError = error as? MyApiError {
if (myApiError == MyApiError.tokenError) {
return Session.shared.myProvider.request(.generateToken)
} else {
return Observable.error(myApiError)
}
}
return Observable.error(error)
})
}
}
}
然后我可以使用它:
Session.shared.myProvider.rx
.request(.mySampleRequest)
.filterSuccessfulStatusCodes()
.retryWithToken()
.subscribe { event in
....
}.disposed(by: self.disposeBag)
但是现在使用 RxSwift 4.0.0 的序列期望
PrimitiveSequence<SingleTrait, Response>
有人可以向我解释如何使用 RxSwift 4.0.0 做同样的事情吗?我尝试对 PrimitiveSequence 进行扩展,但出现了一些编译错误。