kopia lustrzana https://github.com/Yakifo/amqtt
adding test case for issue 67
rodzic
80016d8cca
commit
58d431f2f5
|
@ -295,3 +295,10 @@ async def test_client_publish_will_with_retain(broker_fixture, client_config):
|
||||||
assert message3.topic == 'test/will/topic'
|
assert message3.topic == 'test/will/topic'
|
||||||
assert message3.data == b'client ABC has disconnected'
|
assert message3.data == b'client ABC has disconnected'
|
||||||
await client3.disconnect()
|
await client3.disconnect()
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.asyncio
|
||||||
|
async def test_connect_broken_uri():
|
||||||
|
config = {"auto_reconnect": False}
|
||||||
|
client = MQTTClient(config=config)
|
||||||
|
await client.connect('"mqtt://someplace')
|
||||||
|
|
Ładowanie…
Reference in New Issue