Searched refs:TestChannelKind (Results 1 – 7 of 7) sorted by relevance
14 TestChannelKind.values().forEach { kind -> testSendReceive(kind, 20) } in <lambda>()19 TestChannelKind.values().forEach { kind -> testOffer(kind) } in <lambda>()24 TestChannelKind.values().forEach { kind -> testSendAfterClose(kind) } in <lambda>()29 TestChannelKind.values().forEach { kind -> testReceiveOrNull(kind) } in <lambda>()34 TestChannelKind.values().forEach { kind -> testReceiveOrNullException(kind) } in <lambda>()39 TestChannelKind.values().forEach { kind -> testReceiveOrClosed(kind) } in <lambda>()43 fun testInvokeOnClose() = TestChannelKind.values().forEach { kind -> in <lambda>()59 fun testInvokeOnClosed() = TestChannelKind.values().forEach { kind -> in <lambda>()70 fun testMultipleInvokeOnClose() = TestChannelKind.values().forEach { kind -> in <lambda>()83 TestChannelKind.values().forEach { kind -> in <lambda>()[all …]
81 private fun runAllKindsTest(test: suspend CoroutineScope.(TestChannelKind) -> Unit) { in <lambda>()82 for (kind in TestChannelKind.values()) { in <lambda>()
10 enum class TestChannelKind( class
31 runStressTest(TestChannelKind.ARRAY_1) in <lambda>()36 runStressTest(TestChannelKind.CONFLATED_BROADCAST) in <lambda>()39 private suspend fun runStressTest(kind: TestChannelKind) { in runStressTest()
15 private val kind: TestChannelKind, in <lambda>()22 fun params(): Collection<Array<Any>> = TestChannelKind.values().flatMap { kind -> in <lambda>()
22 class ChannelUndeliveredElementStressTest(private val kind: TestChannelKind) : TestBase() { in <lambda>()27 TestChannelKind.values() in <lambda>()168 … kind == TestChannelKind.LINKED_LIST -> while (sentCnt > lastReceived + 100) yield() in <lambda>()
18 private val kind: TestChannelKind, in <lambda>()28 TestChannelKind.values().map { arrayOf(it, nSenders, nReceivers) } in <lambda>()