如何解决如何公开 StateFlow 但启动和停止底层 Flow
我有一个从设备传感器接收数据的类。我已将回调封装在 callbackFlow
中以获得 Flow
。
private var sensorFlow: Flow<accelerationState> = callbackFlow {
val listener: SensorEventListener = object : SensorEventListener {
override fun onSensorChanged(event: SensorEvent?) {
...
}
override fun onAccuracyChanged(sensor: Sensor?,accuracy: Int) {
...
}
}
sensorManager.registerListener(listener,accelSensor,SensorManager.SENSOR_DELAY_norMAL)
awaitClose() {
sensorManager.unregisterListener(listener,accelSensor)
}
}
理想情况下想公开一个 StateFlow
所以我这样做了:
sensorFlow.stateIn(
scope = scope,started = WhileSubscribed(5000),initialValue = accelerationState(0,0))
我希望能够暂停/恢复传感器读数,我通常会通过注册/取消注册侦听器来执行此操作。我的理解是,如果我想有那种效果,我必须停止听流程,然后重新启动它。
我曾尝试使用 takeWhile { isGathering }
,但在 Flow
被杀死后,它无法再次重新启动。重新声明 StateFlow
没有任何作用,因为应用程序的其余部分存储了先前的引用。
如何公开 StateFlow
但能够更改创建它的基础 Flow
?
编辑:然后在 StateFlow
中简单地引用 viewmodel
,然后可以由视图访问:
val sensorStateFlow = sensorDataRepository.sensorStateFlow
解决方法
如果您要使用流会怎样?
首先,创建一个 MutableStateFlow
来保存“当前”流。它的初始值只是一个空流。
val currentFlow = MutableStateFlow<Flow<T>>(emptyFlow())
然后,启动订阅者将使用的 StateFlow
。这是基于始终收集由 currentFlow
发出的最新流的串联流。
val stateFlow = currentFlow.flatMapLatest { it }.stateIn(scope)
最初,stateFlow
为空(并挂起,因为它没有初始值)。要启动它,您可以设置 currentFlow
的值:
currentFlow.value = createNewSensorFlow()
来自传感器流的值将被收集并通过 stateFlow
获得。为 currentFlow
设置新值将导致串联的 stateFlow
停止侦听(并终止)前一个流并开始从新流收集。要暂停传感器,您可以将值设置回空流:
currentFlow.value = emptyFlow()
您仍然可以在启动状态流时使用 SharingStarted.WhileSubscribed
,以确保在没有订阅者时侦听器不处于活动状态。如果你这样做,当新订阅者到达时,“当前”流将简单地被再次收集。因为您使用的是回调流,所以应该可以正常工作,并且只会再次初始化流以创建新的侦听器。
作为一个简化,如果采样率是您唯一需要改变的,请考虑如下:
val sampleRate = MutableStateFlow<Int?>(null)
val stateFlow = sampleRate.flatMapLatest { sampleRate ->
if (sampleRate == null) {
emptyFlow()
} else {
createSensorFlow(sampleRate)
}
}.stateIn(scope)
这里,我们没有设置 currentFlow
,而是将 sampleRate.value
设置为我们想要的任何值。每次更改时,都会替换“当前流”(现在作为 flatMapLatest
的一部分创建)。我们将 sampleRate.value
设置为 null
以发出空流,从而暂停传感器。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。