如何等待悬浮功能的结果？

Question

我需要将freshcsrf字符串添加到每个请求中。使用okhttpclient带有authinterceptor。问题是如何将请求发送到Interceptor中以获取freshcsrf字符串？

在下面的代码中发生错误，

Suspend function 'getAuth' should be called only from a coroutine or another suspend function

class AuthInterceptor(val authApi: IAuthService) : Interceptor {

    override fun intercept(chain: Interceptor.Chain): Response {
        var request = chain.request()

        val freshCsrf = authApi.getAuth().freshCsrf

        // ... add freshCsrf to form body
        return chain.proceed(request)
    }
}

// Retrofit service
interface IAuthApi {
    @GET("/auth")
    suspend fun getAuth(): Auth
}

我尝试使用coroutine，但也失败了，因为等不及结果。 async/等待案例以错误

Suspend function 'await' should be called only from a coroutine or another suspend function

    private val scope = CoroutineScope(Dispatchers.IO)
    
    override fun intercept(chain: Interceptor.Chain): Response {
        val request = chain.request()

        val freshCsrf = scope.async { authApi.getAuth().freshCsrf }
        freshCsrf.await()
        
        // ... add freshCsrf to form body

        return chain.proceed(request)
    }

更新1

我与runblocking说明相混淆的

示例之一

它设计为桥梁定期阻止代码 以悬浮方式编写，用于主要功能和 测试。

在一侧，改造接口正在暂停，我需要等待网络结果，以便继续创建其他请求（桥梁 - 确定）。但是在另一边，它不是主要功能或测试。而且，许多教程和文章都说必须避免生产代码中的Runblocking。你能解释一下吗？

    override fun intercept(chain: Interceptor.Chain): Response {
        val request = chain.request()

        val freshCsrf = runBlocking {
            return@runBlocking authApi.getAuth().freshCsrf
        }
        
        // ... add freshCsrf to form body

        return chain.proceed(request)
    }

Answer 1

如果您不想使用runblocking，则必须介绍返回call＆lt; auth＆gt;的第二个端点。 呼叫＆lt; auth＆gt;将允许您在其上运行execute（）函数以同步（阻止）方式运行请求。

呼叫接口

文档代码> call.execute ：

class AuthInterceptor(val authApi: IAuthService) : Interceptor {

    override fun intercept(chain: Interceptor.Chain): Response {
        var request = chain.request()

        val freshCrsf = authApi.getAuthCall().execute().let { authResponse ->
            if(authResponse.isSuccessful) {
                authResponse.body().freshCrsf
            } else {
                // TODO handle error for example you can read authResponse.errorBody()
                // and do something based on it
            }
        }

        // ... add freshCsrf to form body
        return chain.proceed(request)
    }
}

// Retrofit service
interface IAuthApi {
    @GET("/auth")
    fun getAuthCall(): Call<Auth>

    @GET("/auth")
    suspend fun getAuth(): Auth
}

我认为runblocking在这种情况下，实际上并不是一个不好的选择。作为文档状态，它用于将悬挂代码桥接到阻止范围。对我来说，主要功能和测试是常见用例。

Answer 2

使用.execute（）而不是.enqueue（），它将同步执行请求。
interceptor不需要，因为CSRF保护通常位于HMTL ＆lt; head＆gt;;
中
如果将字符串放在HTTP标题中，这将是其他事情。

相关文档：代码> 。

Answer 3

interface ApiInterface {
@GET("user/list")
fun userListGet(): Call<UserPageResponse>
}


lifecycleScope.launch {
val response = apiInterface.userListGet().await()
}