hi guys, what is a best replacement for `ConflatedBroadcastChannel(Unit)` using the `StateFlow` or...

# coroutines

[magnumrocha]

hi guys,
what is a best replacement for ConflatedBroadcastChannel(Unit) using the StateFlow or SharedFlow ?
my first try is with a MutableStateFlow<Boolean>(false) and every time I have a change in my logic that dispatch a signal, I do: myflow.value = !myflow.value , but this looks weird 😅

[Erik]

Try a MutableSharedFlow<Unit>(replay = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST) and immediately emit Unit. Not sure if really equivalent, but it should be able to emit the same value multiple times and emitters should never suspend/fail.

[magnumrocha]

thank you, I will try it and make some tests…

[ursus]

so you need to emit duplicated and be able to peek at the last value?

[Erik]

If the type of data is Unit and there always is 1 value, then peeking makes no sense 😉

[magnumrocha]

just to clarify, I use the ConflatedBroadcastChannel(Unit) just as a trigger to notify about some event… this is a easy approach, and StateFlow<Unit> will not work….

[Erik]

Did you make it work with the shared flow?

[magnumrocha]

need to try yet…. sorry 😁

[ursus]

@Erik thats what I was getting at

[magnumrocha]

@Erik the MutableSharedFlow<Unit>(replay = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST) behaviours like a StateFlow
So, I’ve created an object like:

sealed class BaseTriggerEvent {
    override fun equals(other: Any?): Boolean = false
    override fun hashCode(): Int = kotlin.random.Random.nextInt()
}

object TriggerEvent: BaseTriggerEvent()

That never will be equals the same object, so I can use like:

private val refreshTrigger = MutableStateFlow(TriggerEvent)

[magnumrocha]

that’s the best approach I could do so far….