Package-level declarations
Types
Functions
Link copied to clipboard
fun <T : Any> async(contentType: Class<T>, name: String? = null, processor: BiFunction<Event, T, CompletionStage<*>>): EventProcessor
Create an async EventProcessor.
Link copied to clipboard
fun block(coroutineContext: CoroutineContext? = Dispatchers.IO, processor: Consumer<Event>): EventProcessor
fun <T : Any> block(contentType: Class<T>, name: String? = null, coroutineContext: CoroutineContext? = Dispatchers.IO, processor: BiConsumer<Event, T>): EventProcessor
Create a block EventProcessor.
Link copied to clipboard
fun <T : Any> reactive(type: Class<T>, name: String? = null, processor: BiFunction<Event, T, Publisher<*>>): EventProcessor
Create a reactor EventProcessor.