Debounce a Flow's emissions until it is quite for some period

debounceUntilQuiescent.kt

fun <T> Flow<T>.debounceUntilQuiescent(duration: Duration): Flow<T> = channelFlow {
	var job: Job? = null
	collect { value ->
		job?.cancel()
		job = launch {
			delay(duration)
			send(value)
			job = null
		}
	}
}

fun <T> Flow<T>.debounceUntilQuiescentBy(by: (T) -> Any, duration: Duration): Flow<T> = channelFlow {
	val jobs = mutableMapOf<Any, Job>()
	collect { value ->
		val id = by(value)

		jobs[id]?.cancel()
		jobs[id] = launch {
			delay(duration)
			send(value)
			jobs.remove(id)
		}
	}
}