Remove SharedFlowHolder

This commit is contained in:
ganfra 2023-01-11 17:09:14 +01:00
parent 478f516cf1
commit becfda79a2

View file

@ -1,14 +0,0 @@
package io.element.android.x.architecture
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.asSharedFlow
class SharedFlowHolder<Data>(capacity: Int = 64) {
private val mutableFlow: MutableSharedFlow<Data> = MutableSharedFlow(extraBufferCapacity = capacity)
fun asSharedFlow() = mutableFlow.asSharedFlow()
fun emit(data: Data) = mutableFlow.tryEmit(data)
suspend fun awaitEmit(data: Data) = mutableFlow.emit(data)
}