notify(...)

appScope

GlobalScope + CoroutineExceptionHandler

consumeAsFlow()

collect()

class ChannelExample {
    
    private val appScope = GlobalScope + CoroutineExceptionHandler { coroutineContext, throwable -> 
        // Log message + throwable
    }
    private val numbersChannel = Channel<Int>()

    init {
        appScope.launch(Dispatchers.Default) {
            numbersChannel
                .consumeAsFlow()
                .collect { number -> handleNumber(number)}
        }
    }
    
    fun notifyNumber(number: Int) {
        appScope.launch {
            numbersChannel.send(number)
        }
    }

    private suspend fun handleNumber(number: Int) {
        try {
            // Do some computations
        } catch (ce: CancellationException) {
            throw ce
        } catch (ex: Exception) {
            // Log message + exception
        }
    }
}

close()

cancel()

numbersChannel

notifyNumber

offer

consumeAsFlow().collect

consumeEach

RendezvousChannel

notifyNumber()

GlobalScope

"If you do that, then because you're using the consume* APIs the channel will automatically get cancelled when the scope is."

consumeEach

offer

receive

send

receive