|
@@ -83,6 +83,8 @@ class SignaldClient(SignaldRPCClient):
|
|
return True
|
|
return True
|
|
except UnexpectedError as e:
|
|
except UnexpectedError as e:
|
|
self.log.debug("Failed to subscribe to %s: %s", username, e)
|
|
self.log.debug("Failed to subscribe to %s: %s", username, e)
|
|
|
|
+ evt = ListenEvent(action=ListenAction.STOPPED, username=username, exception=e)
|
|
|
|
+ await self._run_event_handler(evt)
|
|
return False
|
|
return False
|
|
|
|
|
|
async def unsubscribe(self, username: str) -> bool:
|
|
async def unsubscribe(self, username: str) -> bool:
|