Add try-except to filter RuntimeError exceptions

Author: bouwew

plugwise_usb/connection/receiver.py

@@ -225,7 +225,13 @@ async def _data_queue_worker(self) -> None:
         """Convert collected data into messages and place then im message queue."""
         _LOGGER.debug("Data queue worker started")
         while self.is_connected:
-            if (data := await self._data_queue.get()) != b"FFFFFFFF":
+            try:
+                data = await self._data_queue.get()
+            except RuntimeError:
+                _LOGGER.debug("No response to add to data_worker_queue")
+                return
+            
+            if data != b"FFFFFFFF":
                 if (response := self.extract_message_from_data(data)) is not None:
                     await self._put_message_in_queue(response)
                 self._data_queue.task_done()
@@ -279,7 +285,12 @@ async def _message_queue_worker(self) -> None:
         """Process messages in receiver queue."""
         _LOGGER.debug("Message queue worker started")
         while self.is_connected:
-            response: PlugwiseResponse = await self._message_queue.get()
+            try:
+                response: PlugwiseResponse = await self._message_queue.get()
+            except RuntimeError:
+                _LOGGER.debug("No response to add to message_worker_queue")
+                return
+
             if response.priority == Priority.CANCEL:
                 self._message_queue.task_done()
                 return