broker/ru.sydis.broker.interfaces/MessageBroker/Companion/subscribeWithFilter

subscribeWithFilter

inline fun <KC : Any, VC : Any> MessageBroker<*, *>.subscribeWithFilter(topic: String, noinline filter: (KC, VC) -> Boolean, noinline onReceive: subscribeCallback<KC, VC>)