無法將類型的值 '（_） - >可觀察<Response>' 預期參數類型 '（[_]） - > _'

Question

我遇到了以下錯誤：

Cannot convert value of type '(_) -> Observable<Response>' 
to expected argument type '([_]) -> _' 

，當我試圖編譯：

func request(_ token: MyAPI) -> Observable<Moya.Response> { 
    switch (target.requiresCSRF, target.requiresOAuth) { 
    case (false, false): return actualRequest 
    case (true, false): return CSRFTokenRequest().flatMap { _ in actualRequest } 
    case (false, true): return OAuthTokenRequest().flatMap { _ in actualRequest } 
    case (true, true): return Observable.zip([CSRFTokenRequest(), OAuthTokenRequest()]) { _ in actualRequest } 
    } 
} 

actualRequest類型爲Observable<Response> 兩個CSRFTokenRequest和OAuthTokenRequest類型爲Observable<String?>

我試圖るn CSRFTokenRequest之前OAuthTokenRequest然後實際請求。

下解決了問題...但我不知道這是做正確的方式...

return RequiresCSRFTokenRequest().flatMap{ _ in 
      self.RequiresAuthenticationRequest().flatMap{ _ in actualRequest} 
     } 



fileprivate extension Networking{ 

    func RequiresAuthenticationRequest() -> Observable<String> { 

     /// This has 3 cases 

     // 0. token is not present, error out 
     // 1. token is not expired, return token 
     // 2. token is expired, needs refresh 

     guard let jwt = AuthManager.shared.accessToken else{ 
      return .just("Error!! No access tokens") 
     } 

     // If access token is valid 
     if AuthManager.shared.expiredAccessToken == false{ 

      return .just(jwt) 

     }else{ 

      return request(.refreshAccessToken(refreshToken: AuthManager.shared.refreshTokenWithBearer!)) 
       .filterSuccessfulStatusCodes() 
       .mapObject(type: UserAuthenticationTokens.self) 
       .do(onNext: { 
        $0.save()}) 
       .map{ (token) -> String in 
        // Get new access token that was just saved 
        return AuthManager.shared.accessToken! 
      } 
     } 

    } 


    func RequiresCSRFTokenRequest() -> Observable<String> { 

     // Always get a new csrf token 
     return request(.getCSRF()) 
      .filterSuccessfulStatusCodes() 
      .mapObject(type: CSRFToken.self) 
      .do(onNext: { 
       $0.save() 
      }).map{ (token) -> String in 
       return AuthManager.shared.csrf_token! 
      } 
    } 

} 

謝謝！

Answer 1

據我可以在你的代碼中看到的，如果你仔細看的switch聲明你的最後一個case，這兩個功能CSRFTokenRequest()和OAuthTokenRequest()正在返回Observables<String?>你正在創建一個新的Observable是等待都發出這樣的事實。

zip爲您發出兩個Observable，在您的情況下，您正在使用{_ return actualRequest}省略兩者。 但要小心，當你要返回函數actualRequest它期望另一件事，所以這裏的重點是將Observable<A>轉換爲Observable<B>。

爲此，您將需要使用flatMap函數，因爲您之前做過，並且在最後一種情況下缺少它。

讓我們看看和例子：

Observable.zip(Observable.just(1), Observable.just("!")) { (a, b) in 
    return (a,b) 
} 
.flatMap { _ in return Observable.just(4.0) } 
.subscribe(onNext: { value in 
    print(value) 
}) 
.addDisposableTo(disposeBag) 

在上述情況下，我省略了Observable<Int>和Observable<String>的兩個值，以創建一個新的Observable<Double>

在你的情況，你應該做這樣的事情：

return Observable.zip(CSRFTokenRequest(), OAuthTokenRequest()).flatMap { _ in actualRequest } 

我希望這可以幫助您