We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ac21c9b commit 0fa3456Copy full SHA for 0fa3456
roborock/devices/local_channel.py
@@ -72,6 +72,8 @@ def _update_encoder_decoder(self, params: LocalChannelParams):
72
)
73
# Callback to decode messages and dispatch to subscribers
74
self._data_received: Callable[[bytes], None] = decoder_callback(self._decoder, self._subscribers, _LOGGER)
75
+ if self._protocol:
76
+ self._protocol.messages_cb = self._data_received
77
78
async def _do_hello(self, local_protocol_version: LocalProtocolVersion) -> LocalChannelParams | None:
79
"""Perform the initial handshaking and return encoder params if successful."""
0 commit comments