Home
last modified time | relevance | path

Searched defs:ReceiveChannel (Results 1 – 3 of 3) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/
DTickerChannelCommonTest.kt110 private fun ReceiveChannel<Int>.averageInTimeWindow(timespan: Long) = GlobalScope.produce { in <lambda>() method
162 fun ReceiveChannel<Unit>.checkEmpty() = assertNull(tryReceive().getOrNull()) in checkEmpty() method
164 fun ReceiveChannel<Unit>.checkNotEmpty() { in checkEmpty() method
/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/
DChannelSinkDepthBenchmark.kt59 private fun ReceiveChannel<Int>.filter( in <lambda>() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DChannel.kt174 public interface ReceiveChannel<out E> { interface