File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -357,7 +357,7 @@ graph LR
3573571 . ** Temporary Subscriptions** : Each RPC creates a temporary subscription that matches the request ID
3583582 . ** Subscription Reuse** : ` MqttSession ` keeps subscriptions alive for 60 seconds (or idle timeout) to enable reuse during command bursts
3593593 . ** Timeout Handling** : Commands timeout after 10 seconds if no response is received
360- 4 . ** Multiple Strategies** : ` V1Channel ` tries local first, then falls back to MQTT if local fails
360+ 4 . ** Multiple Strategies** : ` V1Channel ` tries connect to both Local faster local commands and MQTT for streaming updates.
361361
362362## Class Design & Components
363363
Original file line number Diff line number Diff line change @@ -235,7 +235,7 @@ def decode_data_protocol_message(message: RoborockMessage) -> dict[RoborockDataP
235235 Returns a dict mapping RoborockDataProtocol to values, or None if the
236236 message does not contain any recognized data protocol updates.
237237 """
238- if not (datapoints := _decode_dps_message (message )):
238+ if (datapoints := _decode_dps_message (message )) is None :
239239 return None
240240
241241 result : dict [RoborockDataProtocol , Any ] = {}
You can’t perform that action at this time.
0 commit comments