vertx / io.vertx.rxjava.mqtt / MqttClient / rxSubscribe

# rxSubscribe

`open fun rxSubscribe(topic: String, qos: Int): Single<Int>`

Subscribes to the topic with a specified QoS level

### Parameters

`topic` - topic you subscribe on

`qos` - QoS level

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

### Parameters

`topics` - topics you subscribe on

Return