Searched refs:SafeCollector (Results 1 – 7 of 7) 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()
405 val safeCollector = SafeCollector(collector, currentCoroutineContext()) in <lambda>()
13 internal expect class SafeCollector<T>( in <lambda>() class24 internal fun SafeCollector<*>.checkContext(currentContext: CoroutineContext) { in checkContext()
210 val safeCollector = SafeCollector(collector, coroutineContext) in collect()
11 internal actual class SafeCollector<T> actual constructor( in <lambda>() class
21 internal actual class SafeCollector<T> actual constructor( in <lambda>() class