aboutsummaryrefslogtreecommitdiff
path: root/.venv/lib/python3.12/site-packages/aiostream/__init__.py
diff options
context:
space:
mode:
authorS. Solomon Darnell2025-03-28 21:52:21 -0500
committerS. Solomon Darnell2025-03-28 21:52:21 -0500
commit4a52a71956a8d46fcb7294ac71734504bb09bcc2 (patch)
treeee3dc5af3b6313e921cd920906356f5d4febc4ed /.venv/lib/python3.12/site-packages/aiostream/__init__.py
parentcc961e04ba734dd72309fb548a2f97d67d578813 (diff)
downloadgn-ai-master.tar.gz
two version of R2R are hereHEADmaster
Diffstat (limited to '.venv/lib/python3.12/site-packages/aiostream/__init__.py')
-rw-r--r--.venv/lib/python3.12/site-packages/aiostream/__init__.py31
1 files changed, 31 insertions, 0 deletions
diff --git a/.venv/lib/python3.12/site-packages/aiostream/__init__.py b/.venv/lib/python3.12/site-packages/aiostream/__init__.py
new file mode 100644
index 00000000..3ac80c16
--- /dev/null
+++ b/.venv/lib/python3.12/site-packages/aiostream/__init__.py
@@ -0,0 +1,31 @@
+"""Generator-based operators for asynchronous iteration.
+
+The two main modules are:
+- stream: provide all the stream operators (to create new stream objects)
+- pipe: provides all the pipe operators (to combine operators using '|')
+
+Additionally, three core objects are exposed:
+- streamcontext: a context for safe stream iteration
+- StreamEmpty: the exception raised when an empty stream is awaited
+- operator: a decorator to create stream operators from async generators
+
+Some utility modules are also provided:
+- aiter_utils: utilties for asynchronous iteration
+- context_utils: utilites for asynchronous context
+- test_utils: utilities for testing stream operators (require pytest)
+"""
+
+from . import stream, pipe
+from .aiter_utils import async_, await_
+from .core import StreamEmpty, operator, pipable_operator, streamcontext
+
+__all__ = [
+ "stream",
+ "pipe",
+ "async_",
+ "await_",
+ "operator",
+ "pipable_operator",
+ "streamcontext",
+ "StreamEmpty",
+]