broker/ru.sydis.broker.interfaces.streams/FlowProcessor

FlowProcessor

interface FlowProcessor<K, V>

Интерфейс процессора. Каждый процессор обрабатывает входные данные и передает их дальше.

Functions

Link copied to clipboard
abstract suspend fun process(rec: StreamRecord<K?, V>): StreamRecord<K?, V>?