override suspend fun collect()

in kotlinx-coroutines-core/common/src/flow/SharedFlow.kt [384:402]

• 19 lines of code
• 5 McCabe index (conditional complexity)

    override suspend fun collect(collector: FlowCollector<T>): Nothing {
        val slot = allocateSlot()
        try {
            if (collector is SubscribedFlowCollector) collector.onSubscription()
            val collectorJob = currentCoroutineContext()[Job]
            while (true) {
                var newValue: Any?
                while (true) {
                    newValue = tryTakeValue(slot) // attempt no-suspend fast path first
                    if (newValue !== NO_VALUE) break
                    awaitValue(slot) // await signal that the new value is available
                }
                collectorJob?.ensureActive()
                collector.emitInternal(newValue as T)
            }
        } finally {
            freeSlot(slot)
        }
    }