Impelment EventBus by Flow

EventBus

class EventBus{

    private val event = MutableSharedFlow<Any>()


    fun post(o: Any) = GlobalScope.launch(Dispatchers.IO) {
        event.emit(o)
    }

    inline fun <reified T> subscribeOn(): Flow<T> = event.asSharedFlow()
        .filter { it is T }
        .map { it as T }

}