Kotlin utilities

utils.kt

inline fun <reified T : Any> getLogger() = LoggerFactory.getLogger(T::class.java)!!

fun runInGui(runnable: () -> Unit) = SwingUtilities.invokeLater(Runnable(runnable))

class EventBus {

    private val publisher = PublishSubject.create<Any>()
    private val busExecutor = Executors.newSingleThreadExecutor()

    fun emit(event: Any) {
        log.trace("Event emitted [$event]")
        busExecutor.submit {
            publisher.onNext(event)
        }
    }

    fun <T : Any> on(eventType: KClass<T>, listener: (T) -> Unit) {
        publisher.ofType(eventType.java).subscribe(listener)
    }

    fun <T : Any> onGui(eventType: KClass<T>, listener: (T) -> Unit) {
        publisher.ofType(eventType.java).subscribe { runInGui { listener(it) } }
    }

    companion object {

        val log = getLogger<EventBus>()
    }
}