has anyone run into needing to debounce a channel ...

# coroutines

[withoutclass]

has anyone run into needing to debounce a channel yet?

[Jonathan]

I use

fun <E> ReceiveChannel<E>.debounce(duration: Long, timeUnit: TimeUnit = TimeUnit.MILLISECONDS): ReceiveChannel<E> = produce {
  var job: Job? = null

  consumeEach { element ->
    job?.cancel()
    job = launch(coroutineContext) {
      delay(duration, timeUnit)
      send(element)
    }
  }

  job?.join()
}

[withoutclass]

Very cool, thank you!

[dave08]

https://gist.githubusercontent.com/elizarov/69ff0cf47d9ffe013bc6c1aeaf5af552/raw/da545e0ccad6148b9cbcb0842e87eb941e485756/Debounce.kt

[withoutclass]

Beautiful, I found a similar link from Roman by googling quick.

[withoutclass]

I'll have to take a look at the two versions and compare 😄