Fix exception caused by endpoint abort

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog for aiosenseme library
 
+## v0.5.4
+
+* Fix error caused by adding timeout in v0.5.3.
+
 ## v0.5.3
 
 * Added timeout in listener task to better detect when fans are offline.

aiosenseme/device.py

@@ -120,6 +120,8 @@ async def receive(self) -> str:
         Return None when the socket is closed.
         This method is a coroutine.
         """
+        if not self.transport:
+            return None
         if self.receive_queue.empty() and self.transport.is_closing():
             return None
         return await self.receive_queue.get()
@@ -900,7 +902,7 @@ async def _listener(self):
                 except asyncio.TimeoutError:
                     self._endpoint.abort()
                     data = None
-                    _LOGGER.warning("%s: Device has been quiet too long.", self.name)
+                    _LOGGER.debug("%s: Device has been quiet too long.", self.name)
                 if data is None:
                     # endpoint is closed, let task know it's time open another
                     _LOGGER.warning(

aiosenseme/version.py

@@ -1,3 +1,3 @@
 """Version for aiosenseme library."""
 
-__version__ = "0.5.3"
+__version__ = "0.5.4"