【发布时间】:2019-12-24 10:52:23
【问题描述】:
我创建了一个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)
}
【问题讨论】:
标签: coroutine kotlin-coroutines