Black

Author: olijeffers0n

rustplus/remote/websocket/ws.py

@@ -187,7 +187,9 @@ async def handle_message(self, app_message: AppMessage) -> None:
             event: YieldingEvent = self.responses.get(app_message.response.seq, None)
             if event is not None:
                 if self.debug:
-                    self.logger.info(f"Running Response Event With Error: {app_message}")
+                    self.logger.info(
+                        f"Running Response Event With Error: {app_message}"
+                    )
 
                 event.set_with_value(app_message)
             else:

rustplus/rust_api.py

@@ -388,7 +388,9 @@ async def get_map_info(self) -> Union[RustMap, RustError]:
 
         return RustMap(response.response.map)
 
-    async def get_entity_info(self, eid: int = None) -> Union[RustEntityInfo, RustError]:
+    async def get_entity_info(
+        self, eid: int = None
+    ) -> Union[RustEntityInfo, RustError]:
         """
         Gets entity info from the server
 
@@ -456,7 +458,9 @@ async def check_subscription_to_entity(self, eid: int) -> Union[bool, RustError]
             return RustError("check_subscription_to_entity", "misc")
 
         if error_present(response):
-            return RustError("check_subscription_to_entity", response.response.error.error)
+            return RustError(
+                "check_subscription_to_entity", response.response.error.error
+            )
 
         return response.response.flag.value
 

rustplus/structs/rust_error.py

@@ -16,4 +16,4 @@ def reason(self) -> str:
         return self._reason
 
     def __str__(self) -> str:
-        return f"Error Propagating from {self._method}: {self._reason}"
+        return f"Error Propagating from {self._method}: {self._reason}"