Example code for "The Tale of the Misleading Coroutine Stacktrace" article

solution.kt

import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.channels.Channel.Factory.CONFLATED
import kotlinx.coroutines.channels.ClosedReceiveChannelException
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

class SourceClosed(cause: Throwable) : IllegalStateException(cause)

fun main(args: Array<String>) = runBlocking<Unit> {
    val channel = Channel<Int>(CONFLATED)

    launch {
        try {
            channel.receive()
        } catch (e: ClosedReceiveChannelException) {
            throw SourceClosed(e)
        }
    }

    launch {
        delay(1_000L)
        channel.cancel()
    }
}