reactive
fun <T : Any> reactive(type: Class<T>, name: String? = null, processor: BiFunction<Event, T, Publisher<*>>): EventProcessor(source)
Create a reactor EventProcessor.
Note: if you want to use reactive, you also need to make sure the runtime contain kotlinx.coroutines.reactive.