diff --git a/bfxapi/websocket/exceptions.py b/bfxapi/websocket/exceptions.py index 22917be..e47a1f0 100644 --- a/bfxapi/websocket/exceptions.py +++ b/bfxapi/websocket/exceptions.py @@ -10,7 +10,6 @@ __all__ = [ "WebSocketAuthenticationRequired", "InvalidAuthenticationCredentials", "EventNotSupported", - "HandlerNotFound", "OutdatedClientVersion" ] @@ -54,12 +53,6 @@ class EventNotSupported(BfxWebSocketException): This error indicates a failed attempt to subscribe to an event not supported by the BfxWebSocketClient. """ - -class HandlerNotFound(BfxWebSocketException): - """ - This error indicates that a handler was not found for an incoming message. - """ - class OutdatedClientVersion(BfxWebSocketException): """ This error indicates a mismatch between the client version and the server WSS version. diff --git a/bfxapi/websocket/handlers/authenticated_events_handler.py b/bfxapi/websocket/handlers/authenticated_events_handler.py index ec811b5..b3e1e12 100644 --- a/bfxapi/websocket/handlers/authenticated_events_handler.py +++ b/bfxapi/websocket/handlers/authenticated_events_handler.py @@ -1,5 +1,3 @@ -from ..exceptions import HandlerNotFound - from ...types import serializers from ...types.serializers import _Notification @@ -60,8 +58,6 @@ class AuthenticatedEventsHandler: return self.event_emitter.emit(event, serializer.parse(*stream)) - raise HandlerNotFound(f"No handler found for event of type <{abbrevation}>.") - def __notification(self, stream): event, serializer = "notification", _Notification(serializer=None) diff --git a/bfxapi/websocket/handlers/public_channels_handler.py b/bfxapi/websocket/handlers/public_channels_handler.py index d8d76c7..f32fe14 100644 --- a/bfxapi/websocket/handlers/public_channels_handler.py +++ b/bfxapi/websocket/handlers/public_channels_handler.py @@ -1,5 +1,3 @@ -from ..exceptions import HandlerNotFound - from ...types import serializers class PublicChannelsHandler: @@ -37,8 +35,6 @@ class PublicChannelsHandler: if (channel := subscription["channel"]) and channel in self.__handlers.keys(): return self.__handlers[channel](_clear(subscription, "event", "channel", "chanId"), *stream) - raise HandlerNotFound(f"No handler found for channel <{subscription['channel']}>.") - def __emit(self, event, sub, data): sub_id, should_emit_event = sub["subId"], True