<https://android.jlelse.eu/rxbus-kotlin-listen-where-ever-you-want-e6fc0760a4a8> Hello all, how can ...

# coroutines

[necati]

https://android.jlelse.eu/rxbus-kotlin-listen-where-ever-you-want-e6fc0760a4a8
Hello all, how can I create an event bus like this with current coroutine apis?

[octylFractal]

dispatching events to listeners is up to you, but you can use Channel or Flow to setup async event transfer, e.g. by sending events to Channel and having something receive in a loop and dispatch

[octylFractal]

to replicate "rx", you probably want to use Flow -- publisher field would be a flow derived from a BroadcastChannel, you would also store said channel. publish(e) would send to the channel, and listen(Class) would simply call filterIsInstance on the flow

[asad.awadia]

How do you implement the listener

[octylFractal]

collect?

[asad.awadia]

No i mean how to keep track of listeners since multiple

[octylFractal]

for what?

[necati]

created something like that but couldn’t be sure about runBlocking part

EventBus.kt

[octylFractal]

ideally send should be suspend

[octylFractal]

and if it needs to be blocking, use runblocking at that location, or add a blocking variant that uses sendBlocking

[octylFractal]

also, it's probably better to store a single asFlow() return value, rather than making a new one each time, though I don't think there's a huge difference

[necati]

in this case, i can only call send in a coroutine. i want to call it from adapters etc

[octylFractal]

it's better to use sendBlocking only then

[necati]

looks lovely, thanks

EventBus.kt