kopia lustrzana https://github.com/Yakifo/amqtt
Return return codes from suback
rodzic
ac684e8551
commit
d05e182fc1
|
@ -174,7 +174,7 @@ class MQTTClient:
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def subscribe(self, topics):
|
def subscribe(self, topics):
|
||||||
yield from self._handler.mqtt_subscribe(topics, self.session.next_packet_id)
|
return (yield from self._handler.mqtt_subscribe(topics, self.session.next_packet_id))
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def unsubscribe(self, topics):
|
def unsubscribe(self, topics):
|
||||||
|
|
Ładowanie…
Reference in New Issue