fix: rename error

centrifuge/__init__.py

@@ -24,7 +24,7 @@
 from .exceptions import (
     CentrifugeError,
     ClientDisconnectedError,
-    ClientTimeoutError,
+    OperationTimeoutError,
     DuplicateSubscriptionError,
     ReplyError,
     SubscriptionUnsubscribedError,
@@ -49,7 +49,7 @@
     "ClientState",
     "SubscriptionState",
     "CentrifugeError",
-    "ClientTimeoutError",
+    "OperationTimeoutError",
     "ClientDisconnectedError",
     "SubscriptionUnsubscribedError",
     "DuplicateSubscriptionError",

centrifuge/client.py

@@ -47,7 +47,7 @@
 from centrifuge.exceptions import (
     CentrifugeError,
     ClientDisconnectedError,
-    ClientTimeoutError,
+    OperationTimeoutError,
     DuplicateSubscriptionError,
     ReplyError,
     SubscriptionUnsubscribedError,
@@ -318,7 +318,7 @@ async def _create_connection(self) -> bool:
 
             try:
                 reply = await future
-            except ClientTimeoutError as e:
+            except OperationTimeoutError as e:
                 await self._close_transport_conn()
                 handler = self._events.on_error
                 await handler(ErrorContext(code=_code_number(_ErrorCode.TIMEOUT), error=e))
@@ -601,7 +601,7 @@ async def _subscribe(self, channel):
             await self._send_commands([command])
             try:
                 reply = await future
-            except ClientTimeoutError as e:
+            except OperationTimeoutError as e:
                 if sub.state != SubscriptionState.SUBSCRIBING:
                     return None
                 handler = sub._events.on_error
@@ -670,7 +670,7 @@ async def _unsubscribe(self, channel: str):
 
         try:
             await future
-        except ClientTimeoutError:
+        except OperationTimeoutError:
             code = _ConnectingCode.UNSUBSCRIBE_ERROR
             await self._disconnect(_code_number(code), _code_message(code), True)
             return
@@ -683,7 +683,7 @@ def _register_future(self, cmd_id: int, timeout: float) -> asyncio.Future:
 
             def cb():
                 if not future.done():
-                    self._future_error(cmd_id, ClientTimeoutError())
+                    self._future_error(cmd_id, OperationTimeoutError())
 
             th = self._loop.call_later(timeout, cb)
 
@@ -710,7 +710,7 @@ async def _register_future_with_done(self, cmd_id: int, timeout: float):
 
             def cb():
                 if not future.done():
-                    self._future_error(cmd_id, ClientTimeoutError())
+                    self._future_error(cmd_id, OperationTimeoutError())
 
             th = self._loop.call_later(timeout, cb)
 
@@ -784,7 +784,7 @@ async def ready(self, timeout: Optional[float] = None) -> None:
             timeout=timeout or self._timeout,
         )
         if not completed:
-            raise ClientTimeoutError("timeout waiting for connection to be ready")
+            raise OperationTimeoutError("timeout waiting for connection to be ready")
 
     async def publish(
         self,
@@ -1239,7 +1239,7 @@ async def ready(self, timeout: Optional[float] = None) -> None:
             timeout=timeout or self._client._timeout,
         )
         if not completed:
-            raise ClientTimeoutError("timeout waiting for subscription to be ready")
+            raise OperationTimeoutError("timeout waiting for subscription to be ready")
 
     async def history(
         self,

centrifuge/exceptions.py

@@ -19,8 +19,8 @@ class SubscriptionUnsubscribedError(CentrifugeError):
     """SubscriptionUnsubscribedError raised when an error subscribing on a channel occurred."""
 
 
-class ClientTimeoutError(CentrifugeError):
-    """ClientTimeoutError raised every time operation time out."""
+class OperationTimeoutError(CentrifugeError):
+    """OperationTimeoutError raised every time operation time out."""
 
 
 class ReplyError(CentrifugeError):