bazted
02/09/2018, 11:16 AMonComplete
like listener for ReceiveChannel. for now I have fun <T> ReceiveChannel<T>.onComplete(action: suspend () -> Unit): ReceiveChannel<T> {
launch(Unconfined) {
consumeEach { }
action()
}
return this
}
elizarov
02/09/2018, 9:51 PM