为什么 ConflatedBroadcacstChannel.asFlow() 没有调用 Flow.onCompletion？

Question

在Coroutines+Flow/LiveData 的新 Android 代码实验室中，您更新了 LiveData api 以使用 Flow，但我注意到一些onCompletion未按预期调用的意外行为。我们要替换的 LiveData 代码：

\n\n

viewModelScope.launch {\n  try {\n    _spinner.value = true\n  ...query some data...\n  } catch (error: Throwable) {\n    _snackbar.value = error.message\n  } finally {\n    _spinner.value = false\n  }\n}\n

\n\n

我们在代码实验室结束时得到的流程代码：

\n\n

val growZoneChannel = ConflatedBroadcastChannel<Int>()\n...\ngrowZoneChannel.asFlow()\n       .mapLatest { growZone ->\n           _spinner.value = true\n           ...query some data...\n       }\n       .onCompletion {  _spinner.value = false }\n       .catch { throwable ->  _snackbar.value = throwable.message  }\n       .launchIn(viewModelScope)\n

\n\n

当您运行 Flow 时，微调器永远不会消失，因为即使mapLatest转换完成，也永远不会调用 onCompletion。代码实验室声明，“onCompletion每次上面的流程完成时都会被调用。它与finally块相同\xe2\x80\x93，它是放置清理期间需要执行的任何代码的好地方. 在这里我们正在重置微调器。”

\n\n

但这显然不是真的。那么每次转换后执行黑色代码的正确方法是什么，这是否意味着代码实验室不正确或者我有什么误解？

\n