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

import RxSwift
import Moya
import ObjectMapper
import SwiftyJSON
import Alamofire
//擴(kuò)展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發(fā)送出去
            let responses = updateTokenSuccess.asObservable().flatMapLatest({ _ -> Observable<Response> in  
                return MyProvider.rx.request(target).asObservable()
            })
            
            return responses
            
        }
    }
}

大公告成，主要思路就是發(fā)現(xiàn)token過期后去更新token然后再去請求上一次的請求然后返回respone后面就可以繼續(xù)對response進(jìn)行處理

喜歡就給點(diǎn)個(gè)贊吧！