Hi guys, Anyone can help me on

Flow

or

Channel

in kotlin? I want to build a

Queue

for commands. Thanks

I had this from some time ago. A simplistic version of an Actor. See if it can guide you a little bit. https://github.com/pablichjenkov/Android-Actor/blob/master/app/src/main/java/com/hamperapp/actor/Actor.kt Perhaps there is no need for the atomic check isStarted

I tried with MutableSharedFlow in my project. Response time is very slow to respond back. I read that channel or flow will help to read data from BLE.

Took a an overview of your code. The only thing comes to my mind, is that you are using emit in the shared flow without buffer, meaning the sharedflow will suspend until the consuming endpoint finishes processing the event. Perhaps giving it some buffer and changing the onbufferoverflow behavior speeds it up a little bit

I don't have an idea of buffer in sharedflow

No, they are not equal. A sharedflow has both, replay and extrabuffer. When you set a replay different from 0, it will automatically set a buffer internally greater or equal than the replay but they are 2 different things. If you set extrabuffer and replay it will set the internal buffer to the greater of these 2 parameters. What you need is extrabuffer, let replay in 0 cause otherwise it will mess up you logic. Then pass also in the constructor the onbufferoverflow to drop last

Is it fine to set like this

private val commandFlow =
    MutableSharedFlow<(input: String) -> Unit>(
        extraBufferCapacity = 1,
        onBufferOverflow = BufferOverflow.DROP_OLDEST
    )

?

Are you measuring the throughput of the channel/mutablesharedflow or are you measuring the ble messaging speed. If you refer to the second, it has nothing to do with coroutines at all. Is the phone hardware and the ble nature. I remember working on it and it was slow, by that time a ble characteristic read could only send 20 bytes per packet, it probably changed.

Yes I am measuring the ble messaging speed.

Well, unfortunately there is not much you could do there. Perhaps, check if changing the mtu allows you for bigger messages. And that way you can receive more bytes, at least.

Okk I'll try the best. I really appreciate it...👍