diff --git a/trio_paho_mqtt/trio_paho_mqtt.py b/trio_paho_mqtt/trio_paho_mqtt.py index cb73974..2b88ef0 100644 --- a/trio_paho_mqtt/trio_paho_mqtt.py +++ b/trio_paho_mqtt/trio_paho_mqtt.py @@ -67,7 +67,7 @@ class AsyncClient: with cs: while True: await self._event_should_read.wait() - await trio.hazmat.wait_readable(self.socket) + await trio.lowlevel.wait_readable(self.socket) self._client.loop_read() async def _loop_write(self):