i’m using MutableStateFlow to emit events but while collecting these events i’m adding `delay` for ...

# coroutines

[Kulwinder Singh]

i’m using MutableStateFlow to emit events but while collecting these events i’m adding delay for 500ms but due to this i’m missing all the other data and only last TempData is recieved

GlobalScope.launch() {
            flowMain
                .collect { data ->
                    Log.i("AppLogs", data.toString())
                    delay(1)
                }
        }

viewInputLvlArray.forEachIndexed { index, view ->
    flowMain.value = TempData(index, someotherValue)
}

[Lukas Lechner]

StateFlow only stores one value (state) so I guess you need to use something else like SharedFlow here ...

[Kulwinder Singh]

I have now tried SharedFlow, but in this i have tried tryEmit() that is not working but only emit is working

[Kulwinder Singh]

but with emit i need to run it in coroutine scope @Lukas Lechner

[myanmarking]

looks like you need Channel(Capacity.Unlimited) so you won’t suspend, and won’t lose events

[Lukas Lechner]

Did you set the replay value to something like 15 in your SharedFlow?

[Kulwinder Singh]

i tried replay , it worked but problem is it worked only for first 15 items but list is iterated multiple times in some milliseconds @Lukas Lechner

[Raheel Naz [Amex]]

try emit will fail if you don’t have a buffer.

[Raheel Naz [Amex]]

I would just set the buffer size to 15, suspend on buffer flow and use emit

[Raheel Naz [Amex]]

I think emit will try to do a tryEmit first before it uses a coroutine