Блог

Я хочу создать сопрограммы Kotlin Flow , которые будут выдавать значения, когда

1. они меняются, и
2. периодически выдает последнее доступное значение, каждые x секунд с момента последнего изменения или последнего выброса.

Похоже, это работает-каждый раз, когда приходит новое значение, transformLatest отменяет все предыдущие лямбды и запускает новую. Таким образом, этот подход излучает, а затем продолжает периодически излучать, пока не появится новое значение.

 flow.transformLatest { value ->
  while(currentCoroutineContext().isActive) {
    emit(value)
    delay(x)
  }
}
 

Вы можете создать Flow устройство, которое излучает через регулярные промежутки времени, а затем просто использовать combine . Каждый раз, когда вы объединяете значения, вы на самом деле просто передаете текущее значение Flow интересующего вас оригинала.

     // This is the main flow you are interested in. This uses
    // a Flow builder just as a simple example but this could
    // be any kind of Flow, like a (Mutable)StateFlow.
    val emitter = flow {
        emit("Your data")
        // ...
    }
    // This just serves as a timer.
    val timer = flow {
        while (currentCoroutineContext().isActive) {
            emit(Unit)
            delay(500)
        }
    }
    // This will emit whenever either of the Flows emits and 
    // continues to do so until "emitter" stops emitting.
    combine(
        emitter,
        timer
    ) {  value, ticker ->
        // Always just return the value of your
        // main Flow.
        value
    }