我正在我当前的 Android 项目中调查 Kotlin Coroutine Actors。
目前我有以下类(class)
信使 :
import kotlinx.coroutines.channels.SendChannel
import org.research.development.intentions.action.Sendable
class Messenger<T>(private val sendChannel: SendChannel<T>) : Sendable<T> {
override suspend fun send(message: T) {
sendChannel.send(message)
}
}
查看型号 abstract class BaseViewModel<I, S>(initialState: S) : ViewModel(), ViewModelable<I, S> {
private val sendChannel: SendChannel<I> = viewModelScope.actor {
for (message in channel) {
dispatch(message)
}
}
protected val internalStateFlow = MutableStateFlow(initialState)
val stateFlow: StateFlow<S>
get() = internalStateFlow
private val messenger: Sendable<I> = Messenger(sendChannel)
override fun send(message: I) {
viewModelScope.launch(Dispatchers.IO) {
messenger.send(message)
}
}
}
我想要的是在我的 Messenger 类中声明 Actors sendChannel import kotlinx.coroutines.channels.SendChannel
import org.research.development.intentions.action.Sendable
class Messenger<T>() : Sendable<T> {
private val sendChannel: SendChannel<I> = actor { // viewModelScope????
for (message in channel) {
dispatch(message) // HOW DO I CALL THIS METHOD????
}
}
override suspend fun send(message: T) {
sendChannel.send(message)
}
}
然而,这给我带来了两个问题1). My Actor is no longer within my ViewModelScope
2). How do I call the ViewModel Dispatch method
解决问题2)。我可以将调度函数传递给我的 Messenger 类如何将 Actor 与我的 ViewModelScope 关联?
这整个方法有任何值(value)吗?
最佳答案
您可以通过viewmodelScope
在 Messenger 类中并从该范围调用参与者。
private val sendChannel: SendChannel<I> = viewModelScope.actor {
for (message in channel) {
dispatch(message)
}
}
你也可以覆盖 coroutineContext (我想 Sendable 是 CoroutineScope 的一个子类) override val coroutineContext: CoroutineContext
get() = viewModelScope.coroutineContext
关于android - 如何封装Android Coroutine Actor并仍然与viewModelScope关联,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63741660/