Add unsubscribe testing

pull/8/head
Nicolas Jouanin 2015-07-05 22:00:15 +02:00
rodzic d05e182fc1
commit 5d2126ff63
1 zmienionych plików z 5 dodań i 3 usunięć

Wyświetl plik

@ -9,12 +9,14 @@ C = MQTTClient()
@asyncio.coroutine
def test_coro():
yield from C.connect(uri='mqtt://iot.eclipse.org:1883/', username=None, password=None)
yield from C.subscribe([
ret = yield from C.subscribe([
{'filter': '$SYS/broker/uptime', 'qos': 0x00},
])
logger.info("Subscribed")
yield from asyncio.sleep(60)
logger.info(repr(ret))
yield from asyncio.sleep(10)
yield from C.unsubscribe(['$SYS/broker/uptime'])
logger.info("UnSubscribed")
yield from C.disconnect()