КР
А если использовать conflate + delay?
Так он применяет ко всем, а мне надо только первые N секунд
val time = measureTimeMillis {
foo()
.conflate() // conflate emissions, don't process each one
.collect { value ->
delay(300) // pretend we are processing it for 300 ms
println(value)
}
}
println("Collected in $time ms")
