reactive

fun reactive(processor: Function<Event, Publisher<*>>): EventProcessor(source)
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.