v0ldem0rt
08/13/2018, 7:51 PM@Test
fun `it should initialize with correct initial count`() {
runBlocking(CommonPool) {
val c = Channel<Unit>(Int.MAX_VALUE)
repeat(32) { c.send(Unit) }
assert(c.count() == 32)
}
}