throttleLatest

FlowThrottleLatest.kt

fun <T> Flow<T>.throttleLatest(delayMillis: Long) = this
    .conflate()
    .transform {
        emit(it)
        delay(delayMillis)
    }


import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.flow.toList
import kotlinx.coroutines.test.runTest
import org.junit.Assert.assertEquals
import org.junit.Test

class FlowThrottleTest {

    @Test
    @OptIn(ExperimentalCoroutinesApi::class)
    fun test_throttleLatest() = runTest {
        val flow = flow {
            for (i in 1..32) {
                delay(100)
                emit(i)
            }
        }
        val result = flow.throttleLatest(1000).toList()
        assertEquals(listOf(1, 10, 20, 30, 32), result)
    }
}