How would you implement a timeout that I can kick ...

# coroutines

[reactormonk]

How would you implement a timeout that I can kick to start again each time something happens? Aka I'm looking for a heartbeat-like construct which shuts down an operation if it doesn't receive one every 2 minutes.

[kevin.cianfarini]

https://github.com/kevincianfarini/cardiologist?

[Dmitry Khalanskiy [JB]]

Maybe something like this?

val channel = Channel<Unit>(Channel.CONFLATED)

launch {
  while (true) {
    val result = withTimeoutOrNull(2.minutes) {
      channel.receive()
    }
    if (result == null) {
      shutdown()
      break
    }
  }
}

We do use a construct similar to this internally in kotlinx-coroutines-test.

[reactormonk]

🤔 ah, you reset the doomsday clock by sending something to the channel.

[Joffrey]

I did it like this:
https://github.com/joffrey-bion/krossbow/blob/74ff14a21971cbdfd9523bd3821f5d6c5825e624/krossbow-stomp-core/src/commonMain/kotlin/org/hildan/krossbow/stomp/heartbeats/HeartBeater.kt#L37