fus-api/com.jetbrains.fus.reporting/MessageBus/subscribe

subscribe

fun <T : Any> subscribe(topic: Topic<T>): Flow<T>

fun <T : Any> subscribe(topic: Topic<T>, errorHandler: (Throwable) -> Unit = {}, handle: suspend (message: T) -> Unit): MessageHandler<T>