Searched refs:awaitClose (Results 1 – 13 of 13) sorted by relevance
103 awaitClose { expect(4) } in <lambda>()123 awaitClose { expect(4) } in <lambda>()136 awaitClose { expect(4) } in <lambda>()148 assertFailsWith<IllegalStateException> { (channel as ProducerScope<*>).awaitClose() } in <lambda>()154 awaitClose { expectUnreached() } in <lambda>()
10 import kotlinx.coroutines.channels.awaitClose in <lambda>()38 awaitClose { in <lambda>()
44 awaitClose { in <lambda>()88 awaitClose { in <lambda>()
51 awaitClose() in <lambda>()
191 awaitClose() in <lambda>()
79 socket.awaitClose(5, TimeUnit.SECONDS); in testWebsocketClient()
65 public boolean awaitClose(int duration, TimeUnit unit) throws InterruptedException { in awaitClose() method in SimpleEchoSocket
49 public suspend fun ProducerScope<*>.awaitClose(block: () -> Unit = {}) { in <lambda>() method
95 awaitClose { disposableRef.getAndSet(Disposable.disposed())?.dispose() } in <lambda>()
95 awaitClose { disposableRef.getAndSet(Disposables.disposed())?.dispose() } in <lambda>()
216 awaitClose() in flowViaChannel()
775 …public static final fun awaitClose (Lkotlinx/coroutines/channels/ProducerScope;Lkotlin/jvm/functio…776 …public static synthetic fun awaitClose$default (Lkotlinx/coroutines/channels/ProducerScope;Lkotlin…
140 * Detect missing `awaitClose` calls in `callbackFlow` to make it less error-prone when used with ca…