android - 如何公开 StateFlow 但启动和停止底层 Flow

Question

我有一个从设备传感器接收数据的类。我已将回调包装在 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

Answer 1

如果您要使用流的流怎么办？

首先，创建一个 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 以发出空流，从而暂停传感器。