withoutclass
08/13/2018, 8:21 PM@Test
fun `it should initialize with correct initial count`() {
runBlocking(CommonPool) {
val c = Channel<Unit>(Int.MAX_VALUE)
repeat(32) { c.send(Unit) }
c.close()
assert(c.count() == 32)
}
} is valid and works