Moya 的 RxSwift 扩展之后台无感刷新token

接上一篇文章的.filterSuccess(disposeBag: disposeBag, target: target）的作用
直接上代码

import RxSwift
import Moya
import ObjectMapper
import SwiftyJSON
import Alamofire
//扩展Moya
extension ObservableType where E == Response {
    
    func filterSuccess(disposeBag:DisposeBag,target:MultiTarget) -> Observable<E> {
        return flatMap { (response) -> Observable<E> in
                        
            guard 200 ... 299 ~= response.statusCode else{
                return Observable.just(response)
            }
            
            let json = JSON(data: response.data).dictionaryValue
            guard let code = json["code"]?.intValue else{
                return Observable.just(response)
            }
            
            //处理过期（过期的code是后台定好的）
            guard code == ErrorCode.sys_tokenExpired.rawValue else{
               return Observable.just(response)
            }
            //缓存过期是请求的target
            UserManager.shared.needResendTarget = target
            
            guard let target = UserManager.shared.needResendTarget else{
                fatalError("没有target")
            }
            //更新token
            let updateToken =  MineServices().updateToken()
            //替换本地的token
            updateToken.drive(onNext: { (json) in
                let token = json.dictionaryValue["data"]?.dictionaryValue["token"]?.stringValue
                UserManager.shared.loginInfo.token = token
                UserManager.shared.updateLocalToken(json.dictionaryValue["data"]?.dictionaryValue["token"]?.stringValue ?? "")
            }).disposed(by: disposeBag)
            
            let updateTokenSuccess = updateToken.map{$0.dictionaryValue["code"]?.intValue == 0}

            //利用flatMapLatest把上一次缓存的target发送出去
            let responses = updateTokenSuccess.asObservable().flatMapLatest({ _ -> Observable<Response> in  
                return MyProvider.rx.request(target).asObservable()
            })
            
            return responses
            
        }
    }
}

大公告成，主要思路就是发现token过期后去更新token然后再去请求上一次的请求然后返回respone后面就可以继续对response进行处理

喜欢就给点个赞吧！