Add MQTT subsriber TODO comment
@@ -241,6 +241,7 @@ impl Client {
})
.collect()
}
+ // TODO MQTT subscriber
fn subscriber(&self) {}
fn retry(&self, message_id: String) -> (String, Message) {
let rt = tokio::runtime::Runtime::new().unwrap();
