SharedEventFlow

SharedEventFlow.kt

/**
 * Позволет эммитить сразу нескольким подписчикам все отправленные события.
 * Ждёт, когда появится хотябы один подписчик, а затем отправляем ему все ивенты.
 * credit: @aasitnikov
 */
class SharedEventFlow<T> : FlowCollector<T>, Flow<T> {

    private val sharedFlow = MutableSharedFlow<T>()

    override suspend fun emit(value: T) {
        sharedFlow.subscriptionCount.first { it > 0 } // ждёт пока у sharedFlow появятся подписчики
        sharedFlow.emit(value)
    }

    override suspend fun collect(collector: FlowCollector<T>) {
        sharedFlow.collect(collector)
    }
}