block
fun block(coroutineContext: CoroutineContext? = Dispatchers.IO, processor: Consumer<Event>): EventProcessor(source)
Create a block EventProcessor.
Parameters
coroutineContext
A CoroutineContext used in runInterruptible of the BlockEventProcessor.process. Dispatchers.IO is the default, set to null to use EmptyCoroutineContext.
fun <T : Any> block(contentType: Class<T>, name: String? = null, coroutineContext: CoroutineContext? = Dispatchers.IO, processor: BiConsumer<Event, T>): EventProcessor(source)
Create a block EventProcessor.
Parameters
coroutineContext
A CoroutineContext used in runInterruptible of the BlockEventProcessor.process. Dispatchers.IO is the default, set to null to use EmptyCoroutineContext.
processor
Processor function. (Event sourceEvent, T eventContent) -> { ... }