ChannelsEventBus.kt

public class ChannelsEventBus {
    private val _channels = hashMapOf<KClass<*>, Channel<Any>>()

    private fun createChannel(key: KClass<*>) = synchronized(this) { _channels.getOrPut(key) { Channel(Channel.UNLIMITED) } }

    public fun send(event: Any): Unit = createChannel(event::class).trySend(event).let {  }

    @Suppress("UNCHECKED_CAST")
    public fun <T : Any> receiveAsFlow(type: KClass<T>): Flow<T> = flow {
        createChannel(type)
            .receiveAsFlow()
            .map { it as T }
            .let { emitAll(it) }
    }

    public inline fun <reified T: Any> receiveAsFlow(): Flow<T> = receiveAsFlow(T::class)
}
private data class Event1(val value: Int)
private data class Event2(val value: String)

public fun main(): Unit = runBlocking {
    val bus = ChannelsEventBus()
    bus.send(Event1(1))
    bus.send(Event2("X"))
    launch {
        bus.receiveAsFlow<Event1>().collect { event1: Event1 ->
        }
    }
    launch {
        bus.receiveAsFlow<Event2>().collect { event2: Event2 ->

        }
    }

}

🙏