We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 45f5c58 commit cf6a196Copy full SHA for cf6a196
tests/test_api.py
@@ -30,10 +30,15 @@ def test_can_create_mqtt_roborock():
30
RoborockMqttClient(UserData.from_dict(USER_DATA), device_info)
31
32
33
-def test_sync_connect(mqtt_client):
+@pytest.mark.asyncio
34
+async def test_sync_connect(mqtt_client):
35
with patch("paho.mqtt.client.Client.connect", return_value=mqtt.MQTT_ERR_SUCCESS):
36
with patch("paho.mqtt.client.Client.loop_start", return_value=mqtt.MQTT_ERR_SUCCESS):
- mqtt_client.sync_connect()
37
+ connecting, connected_future = mqtt_client.sync_connect()
38
+ assert connecting is True
39
+ assert connected_future is not None
40
+
41
+ connected_future.cancel()
42
43
44
@pytest.mark.asyncio
0 commit comments