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 b954c9c commit bf8c8d5Copy full SHA for bf8c8d5
roborock/local_api.py
@@ -86,8 +86,7 @@ async def _main_coro(self):
86
await self.on_message(self.device_id, message)
87
except Exception as e:
88
_LOGGER.exception(e)
89
- except Exception as e:
90
- _LOGGER.exception(e)
+ except BrokenPipeError:
91
self.socket.close()
92
93
async def connect(self):
@@ -110,4 +109,6 @@ async def send_message(self, data: bytes):
110
109
raise RoborockTimeout(
111
f"Timeout after {self.timeout} seconds waiting for response"
112
) from None
113
+ self.socket.close()
114
return response
0 commit comments