File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -78,7 +78,7 @@ def __init__(
7878 self ._stick_future : futures .Future | None = None
7979 self ._responses : dict [bytes , Callable [[PlugwiseResponse ], None ]] = {}
8080 self ._stick_response_future : futures .Future | None = None
81- self ._msg_processing_task : Task | None = None
81+ self ._receive_worker_task : Task | None = None
8282 self ._delayed_processing_tasks : dict [bytes , TimerHandle ] = {}
8383 # Subscribers
8484 self ._stick_event_subscribers : dict [
@@ -185,8 +185,8 @@ def _put_message_in_receiver_queue(self, response: PlugwiseResponse) -> None:
185185 """Put message in queue."""
186186 _LOGGER .debug ("Add response to queue: %s" , response )
187187 self ._receive_queue .put_nowait (response )
188- if self ._msg_processing_task is None or self ._msg_processing_task .done ():
189- self ._msg_processing_task = self ._loop .create_task (
188+ if self ._receive_worker_task is None or self ._receive_worker_task .done ():
189+ self ._receive_worker_task = self ._loop .create_task (
190190 self ._receive_queue_worker (),
191191 name = "Receive queue worker"
192192 )
You can’t perform that action at this time.
0 commit comments