so I modified my original example to avoid the communication kotlinlang #coroutines

so I modified my original example to avoid the com...

uhe

03/17/2017, 2:25 PM

so I modified my original example to avoid the communication deadlock by just flushing the remaining elements like so:

Copy code

fun <T> Channel<T>.closeAndFlush(cause: Throwable? = null) {
    close(cause)
    while (poll() != null) {}
}