open fun rxSubscribe(topic: String, qos: Int): Single<Int>
Subscribes to the topic with a specified QoS level
topic - topic you subscribe on
Return
open fun rxSubscribe(topics: MutableMap<String, Int>): Single<Int>
Subscribes to the topic and adds a handler which will be called after the request is sent
topics - topics you subscribe on
Return