chore: remove pending rpcs object

Author: allenporter

roborock/devices/a01_channel.py

@@ -54,9 +54,9 @@ async def send_decoded_command(
         await mqtt_channel.publish(roborock_message)
         return {}
 
-    # This can be simplified if we can assume a all results are returned in 
-    # single response. Otherwise, this will construct a result by merging in
-    # responses that contain the ids that were queried.
+    # Merge any results together than contain the requested data. This
+    # does not use a future since it needs to merge results across responses.
+    # This could be simplified if we can assume there is a single response.
     finished = asyncio.Event()
     result: dict[int, Any] = {}
 

roborock/devices/mqtt_channel.py

@@ -10,7 +10,6 @@
 from roborock.roborock_message import RoborockMessage
 
 from .channel import Channel
-from .pending import PendingRpcs
 
 _LOGGER = logging.getLogger(__name__)
 
@@ -29,8 +28,6 @@ def __init__(self, mqtt_session: MqttSession, duid: str, local_key: str, rriot:
         self._rriot = rriot
         self._mqtt_params = mqtt_params
 
-        # RPC support
-        self._pending_rpcs: PendingRpcs[int, RoborockMessage] = PendingRpcs()
         self._decoder = create_mqtt_decoder(local_key)
         self._encoder = create_mqtt_encoder(local_key)
         self._mqtt_unsub: Callable[[], None] | None = None