如何在应用表达式中调用挂起函数

Question

我想在 apply { } 块中调用挂起函数。
我有一个：

private suspend fun retrieve(accountAction: AccountAction): Any

suspend fun login() {  
 accountEvent.apply {  
  retrieve(it)
}

我试图用suspend { retrieve(it) }runblocking { retrieve(it) } 包围它，但似乎即使它没有产生错误（只能在协程主体内调用暂停函数）代码也没有进入检索函数，而只是通过通过它，这就是我的单元测试失败的原因。

仅供参考：这是一个类，而不是一个活动或片段。

编辑：

这是实际代码（来自评论）：

override suspend fun login(webView: WebView) = trackingId()       
    .flatMap { id -> AccountAction(client, id, WeakReference(webView), upgradeAccount) }
    .map {
        it.apply {       
            upgradeWebViewProgress(webView)
            suspend { retrieve(it) }  
        }
    }       
   .flatMap { updateAuth(it) }

Answer 1

已编辑：

这显示了一个不使用 map 的替代方法，因为我对这个示例的选择并不真正需要它（除非你真的想链接你的所有调用）

suspend fun login(webView: WebView) { 
  val result = trackingId().flatMap { id -> AccountAction(client, id, WeakReference(webView), upgradeAccount) } 
  
  upgradeWebViewProgress(webView) 

  return retrieve(result).flatMap { updateAuth(it) } }

Answer 2

当您想对这样的元素列表执行异步（挂起）操作时，可以使用Flow-API。您可以在此处阅读有关该 API 的信息：https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/-flow/

让您的示例工作的最简单方法可能是将您的列表转换为Flow，执行挂起操作，然后转换回List。像这样：

override suspend fun login(webView: WebView) = trackingId()       
    .flatMap { id -> AccountAction(client, id, WeakReference(webView), upgradeAccount) }
    .asFlow()
    .map {
        it.apply {       
            upgradeWebViewProgress(webView)
            retrieve(it)
        }
    }
    .toList()
    .flatMap { updateAuth(it) }

请注意，这可能不是最有效的，因为它将按顺序执行retrieve-操作。例如，您可以在Flow 上使用其他运算符来并行执行这些操作。