Skip to content

Commit 341d96d

Browse files
committed
feat: Apply suggestions from code review
1 parent 5c33055 commit 341d96d

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

roborock/devices/mqtt_channel.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,10 +34,7 @@ async def subscribe(self, callback: Callable[[bytes], None]) -> Callable[[], Non
3434
"""Subscribe to the device's response topic.
3535
3636
The callback will be called with the message payload when a message is received.
37-
If already subscribed, raises ValueError.
3837
3938
Returns a callable that can be used to unsubscribe from the topic.
4039
"""
41-
if self._unsub:
42-
raise ValueError("Already subscribed to the response topic")
4340
return await self._mqtt_session.subscribe(self._subscribe_topic, callback)

0 commit comments

Comments
 (0)