mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

python 3.10 differentiates between asyncio.TimeoutError and builtin TimeoutError

pull/248/head
Andrew Mirsky 2025-07-02 14:13:02 -04:00
rodzic 51d8c838f7
commit d0d875ca30
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: A98E67635CDF2C39
1 zmienionych plików z 2 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

4
tests/test_broker.py
Wyświetl plik

@ -677,7 +677,7 @@ async def test_client_subscribe_publish_dollar_topic_2(broker):
@pytest.mark.asyncio @pytest.mark.asyncio
async def test_client_publish_clean_session_subscribe(broker): async def test_client_publish_clean_session_subscribe(broker):
sub_client = MQTTClient(client_id='test_client') sub_client = MQTTClient(client_id='test_client', config={'auto_reconnect': False})
await sub_client.connect("mqtt://127.0.0.1", cleansession=False) await sub_client.connect("mqtt://127.0.0.1", cleansession=False)
ret = await sub_client.subscribe( ret = await sub_client.subscribe(
[("/qos0", QOS_0), ("/qos1", QOS_1), ("/qos2", QOS_2)], [("/qos0", QOS_0), ("/qos1", QOS_1), ("/qos2", QOS_2)],
@ -707,7 +707,7 @@ async def test_client_publish_clean_session_subscribe(broker):
while True: while True:
message = await sub_client.deliver_message(timeout_duration=1) message = await sub_client.deliver_message(timeout_duration=1)
assert message is not None, "no other messages should have been retained" assert message is not None, "no other messages should have been retained"
except TimeoutError: except asyncio.TimeoutError:
pass pass
await sub_client.disconnect() await sub_client.disconnect()