如何公开 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 以发出空流，从而暂停传感器。