Я работаю с Kotlin SharedFlows и пытаюсь получить только последнее значение, отправленное потоком. Я пробовал использовать оператор Last(), но он не работает должным образом.
main
fun main(): Unit = runBlocking {
val eventBus = EventBus()
launch {
val latestValue = eventBus.value.lastOrNull()
if (latestValue != null) {
println("Latest value: $latestValue")
}
}
launch {
repeat(5) {
eventBus.increment(it)
}
}
launch {
delay(5.seconds)
(5..10).forEach {
eventBus.increment(it)
}
}
}
EventBus
class EventBus {
private val _value = MutableSharedFlow()
val value: SharedFlow = _value.asSharedFlow()
suspend fun increment(number: Int) {
_value.emit(number)
}
}
Объяснение
Я хочу захватить только последнее значение, выданное наблюдаемым. Например, если наблюдаемый объект выдает значения от 0 до 4, а затем делает паузу на некоторое время, а затем следуют значения от 5 до 10, я хочу сохранить только последнее значение для каждого интервала. Для начального интервала (от 0 до 4) я хочу сохранить 4, а для второго интервала (от 5 до 10) я хочу сохранить 10. Это достижимо?
Спасибо< /p>
ОБНОВЛЕНИЕ
После предложения @Tenfour04 я попробовал некоторый код, но он не печатает последнее значение 2-го интервала.
ОБНОВЛЕНИЕ
После предложения @Tenfour04 я попробовал некоторый код, но он не печатает последнее значение 2-го интервала.
ОБНОВЛЕНИЕ
После предложения @Tenfour04 я попробовал некоторый код, но он не печатает последнее значение 2-го интервала. р>
fun main(): Unit = runBlocking {
val eventBus = EventBus()
launch {
repeat(5) {
eventBus.increment(it)
}
}
launch {
delay(5.seconds)
(5..10).forEach {
delay(100)
eventBus.increment(it)
}
}
launch {
val latestValue = eventBus.value.replayCache.firstOrNull()
if (latestValue != null) {
println("Latest value: $latestValue")
}
}
}
class EventBus {
private val _value = MutableSharedFlow(replay = 1)
val value: SharedFlow = _value.asSharedFlow()
suspend fun increment(number: Int) {
_value.emit(number)
}
}
Подробнее здесь: https://stackoverflow.com/questions/777 ... in-android
