Skip to content

Commit 6ebbb26

Browse files
committed
check close count
1 parent dc36134 commit 6ebbb26

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tests/test_reconnect.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ class FakeConnectionManager:
2929

3030
def __init__(self, socket):
3131
self._socket = socket
32+
self.close_cnt = 0
3233

3334
def get_socket( # noqa: PLR0913, Too many arguments
3435
self,
@@ -47,7 +48,7 @@ def get_socket( # noqa: PLR0913, Too many arguments
4748
return self._socket
4849

4950
def close_socket(self, socket) -> None:
50-
pass
51+
self.close_cnt += 1
5152

5253

5354
def handle_subscribe(client, user_data, topic, qos):
@@ -202,4 +203,5 @@ def test_reconnect(topics, to_send) -> None:
202203
mqtt_client.reconnect()
203204

204205
assert user_data.get("disconnect") == True
206+
assert mqtt_client._connection_manager.close_cnt == 1
205207
assert set(user_data.get("topics")) == set([t[0] for t in topics])

0 commit comments

Comments
 (0)