我有一个从设备传感器接收数据的类。我已将回调包装在 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,0))
我希望能够暂停/恢复传感器读数,而我通常会通过注册/注销监听器来这样做。我的理解是,如果我想达到那种效果,我必须停止收听流程然后重新启动它。
我试过使用 takeWhile { isGathering }
但在 Flow
被杀死后它无法再次重新启动。重新声明 StateFlow
不会执行任何操作,因为应用程序的其余部分存储了之前的引用。
我如何公开一个 StateFlow
但又能够更改创建它的基础 Flow
?
编辑:StateFlow
然后在 ViewModel
中被简单地引用,然后可以被 View 访问:
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
以发出空流,从而暂停传感器。
https://stackoverflow.com/questions/68446039/
相关文章:
javascript - 在开始下一个功能之前等待一个功能完成
python - Pycharm调试Django项目(Dev分支)的问题
postgresql - psql:致命:用户 ""aws rds Postgresql 的 PAM
c++ - std::reference_wrapper
javascript - 来自 "pages/[...slug].js"的 Next.js 路由不起
ios - flutter app 不是由 flutter build ios 运行,而是由 xco