Обработка событий с сервера

Есть какая-то реализация соединения с сервером. Сервер посылает какой-то поток событий. Каждое событие - JSON объект. Разные части приложения слушают разные события. Написать эффективную модель для работы разных частей приложения с этими событиями

kotlininterface ServerConnection {

    // Emits events in JSON format
    fun event(): Flow<String>
}