subscribe

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

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

Parameters

callback

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