Searched refs:currentCoroutineContext (Results 1 – 18 of 18) sorted by relevance
77 val safeCollector = SafeCollector<T>(this, currentCoroutineContext()) in onStart()159 val sc = SafeCollector(this, currentCoroutineContext()) in onCompletion()188 val collector = SafeCollector(this, currentCoroutineContext()) in onEmpty()
274 currentCoroutineContext().ensureActive() in collect()328 val originalContext = currentCoroutineContext().minusKey(Job) in flowWith()
405 val safeCollector = SafeCollector(collector, currentCoroutineContext()) in <lambda>()
44 …flow.onEach { if (it > 10) currentCoroutineContext().cancel() }.launchIn(this + Dispatchers.Defaul… in <lambda>()50 …val channel = flow.onEach { if (it > 10) currentCoroutineContext().cancel() }.produceIn(this + Dis… in <lambda>()
21 val currentContext = currentCoroutineContext() in <lambda>()
18 if (it != 0) currentCoroutineContext().cancel() in <lambda>()
31 currentCoroutineContext().cancel() in <lambda>()
36 while (currentCoroutineContext().isActive) { in <lambda>()
28 assertEquals("FlowCtx", currentCoroutineContext()[CoroutineName]?.name) in <lambda>()
86 …assertFailsWith<TestException> { flow.stateIn(CoroutineScope(currentCoroutineContext() + Job() + c… in <lambda>()
593 currentCoroutineContext().cancel() in <lambda>()786 currentCoroutineContext().cancel() in <lambda>()
259 public suspend inline fun currentCoroutineContext(): CoroutineContext = coroutineContext method
131 while (currentCoroutineContext().isActive) { in <lambda>()
331 val collectorJob = currentCoroutineContext()[Job] in collect()
306 val collectorJob = currentCoroutineContext()[Job] in collect()
98 * New `currentCoroutineContext` function to use unambiguously in the contexts with `CoroutineScope`…1133 * Removed `currentCoroutineContext` and related thread-locals without replacement.
218 …public static final fun currentCoroutineContext (Lkotlin/coroutines/Continuation;)Ljava/lang/Objec…