Shares events across activities, services, etc. So much simpler than the Java version! But still useful.

EventBus.kt

package com.odbol.utils

import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.MutableStateFlow

/** Shares events across activities, services, etc */
object EventBus {
    val events = MutableStateFlow<Event>(Event.None)
}

sealed class Event {
    data object None : Event()
    data class OnError(val error: String) : Event()
    
    // Add your own events here...
}

ExampleActivity.kt

// Example of how to use it in an Activity or wherever
fun onCreate() {
  lifecycleScope.launch(Dispatchers.IO) {
    EventBus.events.collect { event ->
      when (event) {
        is Event.None -> Log.v(TAG, "Subscribing to event bus")
        is Event.OnError -> Log.e(TAG, "Error: ${event.error}")
      }
    }
  }
}