启动多个暂停乐趣

Question

我创建了一个 TextWatcher 扩展来监听带有去抖动的文本更新。我将 TextWatcher 包装到 callbackFlow 中，它通过 Flow.

提供文本输入

问题是调用 collect() 会暂停处理，我需要为多个 EditText 注册它。在 scope 中调用多个 launch 是否正确？

private fun initListeners() = lifecycleScope.launch {
        launch {
            edittext_taskdetail_title.textChangedFlow()
                .collect { text -> viewModel.updateTitle(text) }
        }

        launch {
            edittext_taskdetail_description.textChangedFlow()
                .collect { text -> viewModel.updateDescription(text) }
        }
    }

这是分机：

fun TextView.textChangedFlow(): Flow<String> {
    val flow: Flow<String> = callbackFlow {
        val listener = object : TextWatcher {
            override fun afterTextChanged(s: Editable?) {}

            override fun beforeTextChanged(s: CharSequence?, start: Int, count: Int, after: Int) {}

            override fun onTextChanged(s: CharSequence?, start: Int, before: Int, count: Int) {
                offer(s.toString())
            }
        }
        addTextChangedListener(listener)
        awaitClose { removeTextChangedListener(listener) }
    }

    return flow.debounce(TEXT_UPDATE_DEBOUNCE)
}

Answer 1

我认为你所拥有的是可以接受的，但这里有一个替代方案。

private fun initListeners() {
    edittext_taskdetail_title.textChangedFlow()
        .onEach { text -> viewModel.updateTitle(text) }
        .launchIn(lifecycleScope)

    edittext_taskdetail_description.textChangedFlow()
        .onEach { text -> viewModel.updateDescription(text) }
        .launchIn(lifecycleScope)
}

我做了几乎相同的事情，除了如果其中一个由于某种原因失败，另一个不会立即被取消。

启动多个暂停乐趣

Launch multiple suspend fun

coroutine

kotlin-coroutines