Searched refs:collectContext (Results 1 – 7 of 7) sorted by relevance
15 collectContext: CoroutineContext in <lambda>()18 internal val collectContext: CoroutineContext in <lambda>() constant27 val collectElement = collectContext[key] in checkContext()86 "\t\tFlow was collected in $collectContext,\n" + in checkContext()
175 val collectContext = coroutineContext in collectTo() constant176 val newContext = collectContext + context // compute resulting collect context in collectTo()178 if (newContext == collectContext) in collectTo()181 if (newContext[ContinuationInterceptor] == collectContext[ContinuationInterceptor]) in collectTo()
13 internal actual val collectContext: CoroutineContext in <lambda>() constant in kotlinx.coroutines.flow.internal.SafeCollector17 internal actual val collectContextSize = collectContext.fold(0) { count, _ -> count + 1 } in <lambda>()
16 val collectContext = currentContext in <lambda>() constant27 assertEquals(collectContext.minusKey(Job), currentContext.minusKey(Job)) in <lambda>()
74 val collectContext = coroutineContext in <lambda>() constant76 if (newDispatcher == null || newDispatcher == collectContext[ContinuationInterceptor]) { in <lambda>()78 return collectImpl(collectContext + context, collector) in <lambda>()
23 @JvmField internal actual val collectContext: CoroutineContext in <lambda>() constant in kotlinx.coroutines.flow.internal.SafeCollector31 internal actual val collectContextSize = collectContext.fold(0) { count, _ -> count + 1 } in <lambda>()