Searched refs:collectToFun (Results 1 – 2 of 2) sorted by relevance
52 return scope.produce(context, capacity, block = collectToFun) in create()90 return scope.produce(context, capacity, block = collectToFun) in additionalToStringProps()
59 internal val collectToFun: suspend (ProducerScope<T>) -> Unit constant in kotlinx.coroutines.flow.internal.ChannelFlow119 …ce(context, produceCapacity, onBufferOverflow, start = CoroutineStart.ATOMIC, block = collectToFun) in create()