我遇到了以下错误:

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?> 类型

我试图在 OAuthTokenRequest 之前运行 CSRFTokenRequest，然后是实际请求。

以下解决了问题...但我不确定这是否是正确的方法...

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!
            }
    }

}

谢谢!

最佳答案

如果您仔细观察 switch 中的最后一个案例，我可以在您的代码中看到声明和两个函数的事实 CSRFTokenRequest()和 OAuthTokenRequest()正在返回 Observables<String?>你正在创建一个新的 Observable等待两者都发出。

zip为您发出两个 Observables，在您的情况下，您使用 { _ 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 }

希望对你有帮助

关于swift - 无法将类型 '(_) -> Observable<Response>' 的值转换为预期的参数类型 '([_]) -> _'，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40943500/