使用Coroutine进行连续数据轮询并将其倾倒到UI

Question

我现有的Android代码使用asynctask从虚拟com 端口连续进行轮询数据，并通过覆盖onprogressupdate（）函数来将数据转移到UI线程中。如下：

open class ComActivity(deviceID:Int, listener: OnComRxUpdateUI) : AsyncTask<..., ..., ...>(){
  ...   
  override fun doInBackground(...) { 
  ...   //keep listening on serial port and transfer byte to buffer when available
  }

  override fun onProgressUpdate(...){
  ...  //dump to ui 
  }  
}

上面的代码正常工作（除了在此处和那里进行一些内存泄漏警告外）。

时不时地，我看到coroutine被促进以执行并发和异步操作，并且发现被迫尝试用coroutine替换asynctask。 OTOH，我没有完全掌握coroutines的工作，以替代asynctask。因此，我的问题是coroutine是否是可行的更换我的用例（连续数据轮询和在UI上倾倒）。任何优秀的高级（或伪）例子 欢迎在那里证明这种用例。

Answer 1

很难假设您在asynctask的串行端口上的收听方式，无论您是使用某种侦听器还是无限循环，但是我想使用 flow 和mvvm方法。它的外观如下：

在存储库类中：

fun listenPort(): Flow<String> = flow {
    // keep listening on serial port, use emit() function to emit data
    while (true) {
        val data = listen()
        emit(data)
    }
}

suspend fun listen() = withContext(Dispatchers.IO) {
    // listening on serial port
}

在viewModel中：

private val _state = MutableStateFlow<State>(Loading)
val state = _state

init {
    repository.listenPort()
        .onEach { data ->
            _state.value = Dump(data)
        }.launchIn(viewModelScope)
}

states：

sealed interface State
object Loading : State
data class Dump(val data: ...) : State

in UI（activity或fragment）：

vm.state
        .flowWithLifecycle(lifecycle)
        .onEach { state ->
            // handle all states
            if (state is Dump) {
                val data = state.data
                // use data
            }
    }.launchIn(lifecycleScope)

---

如果您不是是使用mvvm体系结构的方法的粉丝，您可以在UI类中完成所有操作（活动或fragment），我我不喜欢t建议：

listenPort().flowWithLifecycle(lifecycle)
        .onEach { data ->
            // use data
        }.launchIn(lifecycleScope)