internal suspend fun listenForPackets(packetBroadcastChannel: BroadcastChannel<Packet>, 
    activityActionChannel: SendChannel<Action>) {
    val packetReceiveChannel = packetBroadcastChannel.openSubscription()
    try {
        while (isActive) {
            delay(4000)
            var count = 0
            while (!packetReceiveChannel.isEmpty) {
                packetReceiveChannel.receive()
                count++
            }

            when (count) {
                0 -> activityActionChannel.send(Action.DoThing)
            }

        }
    } finally {
        withContext(NonCancellable) {
            packetReceiveChannel.cancel()
        }
    }
}

BroadcastChannel

use()

openSubscription().use {}