remove Abstractclass

Author: atstaeff

eventsourcingdb/abstract_base_client.py

@@ -11,7 +11,6 @@
 from .handlers.parse_raw_message import parse_raw_message
 from .handlers.is_event import is_event
 
-from .abstract_base_client import AbstractBaseClient
 from .errors.custom_error import CustomError
 from .errors.internal_error import InternalError
 from .errors.invalid_parameter_error import InvalidParameterError
@@ -33,7 +32,7 @@
 T = TypeVar('T')
 
 
-class Client(AbstractBaseClient):
+class Client():
     def __init__(
         self,
         base_url: str,
@@ -164,7 +163,7 @@ async def read_events(
         options: ReadEventsOptions
     ) -> AsyncGenerator[Event]:
         async def __read_events(
-            client: AbstractBaseClient,
+            client: Client,
             subject: str,
             options: ReadEventsOptions
         ) -> AsyncGenerator[Event]:
@@ -244,7 +243,7 @@ async def observe_events(
         options: ObserveEventsOptions
     ) -> AsyncGenerator[Event]:
         async def __observe_events(
-            client: AbstractBaseClient,
+            client: Client,
             subject: str,
             options: ObserveEventsOptions
         ) -> AsyncGenerator[Event]:
@@ -338,7 +337,7 @@ async def read_subjects(
         base_subject: str
     ) -> AsyncGenerator[str]:
         async def __read_subjects(
-            client: AbstractBaseClient,
+            client: Client,
             base_subject: str
         ) -> AsyncGenerator[str]:
             request_body = json.dumps({
@@ -383,7 +382,7 @@ async def __read_subjects(
 
     async def read_event_types(self) -> AsyncGenerator[EventType]:
         async def __read_event_types(
-            client: AbstractBaseClient,
+            client: Client,
         ) -> AsyncGenerator[EventType]:
             response: Response
             try:

eventsourcingdb/client.py

@@ -5,7 +5,7 @@
 from .is_event_type import is_event_type
 from ..is_stream_error import is_stream_error
 from ..parse_raw_message import parse_raw_message
-from ...abstract_base_client import AbstractBaseClient
+from ...client import Client
 from ...errors.custom_error import CustomError
 from ...errors.internal_error import InternalError
 from ...errors.server_error import ServerError
@@ -20,7 +20,7 @@
 
 
 async def read_event_types(
-    client: AbstractBaseClient,
+    client: Client,
 ) -> AsyncGenerator[EventType, None]:
     response: Response
     try: