diff --git a/trio_paho_mqtt/trio_paho_mqtt.py b/trio_paho_mqtt/trio_paho_mqtt.py index 1d0d0b7..cb73974 100644 --- a/trio_paho_mqtt/trio_paho_mqtt.py +++ b/trio_paho_mqtt/trio_paho_mqtt.py @@ -76,7 +76,7 @@ class AsyncClient: with cs: while True: await self._event_large_write.wait() - await trio.hazmat.wait_writable(self.socket) + await trio.lowlevel.wait_writable(self.socket) self._client.loop_write() def connect(self, host, port=1883, keepalive=60, bind_address="", bind_port=0, **kwargs):