Remove SharedFlowHolder

This commit is contained in:
ganfra
2023-01-11 17:09:14 +01:00
parent f470f2a6af
commit c2643d0967

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)
}