Skip to content

Commit ec29b2e

Browse files
committed
Force response to prio-queue with nowait
1 parent 746526a commit ec29b2e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

plugwise_usb/connection/receiver.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -269,7 +269,7 @@ async def _put_message_in_queue(
269269
if delay > 0.0:
270270
await sleep(delay)
271271
_LOGGER.debug("Add response to queue: %s", response)
272-
await self._message_queue.put(response)
272+
self._message_queue.put_nowait(response)
273273
if self._message_worker_task is None or self._message_worker_task.done():
274274
_LOGGER.debug("Queue: start new worker-task")
275275
self._message_worker_task = self._loop.create_task(

0 commit comments

Comments
 (0)