无法将类型的值 '（_） - >可观察<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 } 

我希望这可以帮助您