broker/ru.sydis.broker.interfaces.streams/Processor

Processor

interface Processor<K, V>

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

Inheritors

Functions

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