diff options
Diffstat (limited to 'R2R/r2r/base/parsers/base_parser.py')
-rwxr-xr-x | R2R/r2r/base/parsers/base_parser.py | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/R2R/r2r/base/parsers/base_parser.py b/R2R/r2r/base/parsers/base_parser.py new file mode 100755 index 00000000..f1bb49d7 --- /dev/null +++ b/R2R/r2r/base/parsers/base_parser.py @@ -0,0 +1,14 @@ +"""Abstract base class for parsers.""" + +from abc import ABC, abstractmethod +from typing import AsyncGenerator, Generic, TypeVar + +from ..abstractions.document import DataType + +T = TypeVar("T") + + +class AsyncParser(ABC, Generic[T]): + @abstractmethod + async def ingest(self, data: T) -> AsyncGenerator[DataType, None]: + pass |