MessageBus

class MessageBus(scope: CoroutineScope)

Lightweight pub/sub message bus for intra-component communication.

DO NOT call MessageBus outside of components. MessageBus will become fully internal at some point.

Constructors

constructor(scope: CoroutineScope)

fun <T : Any> publish(topic: Topic<T>, data: T)

Publishes a message to the given topic.

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>