subscribe

open override fun subscribe(callback: (p: Int, K?, V, Long) -> Unit)

Подписка на источник данных.

callback

Функция обратного вызова, вызываемая при получении нового сообщения. Принимает ключ и значение сообщения.