folders: rename _base.py and _itertools.py into _visitor.py and _func…

…tions.py
ebonnal · Jan 23, 2024 · 278e7e2 · 278e7e2
1 parent ace78d3
commit 278e7e2
Show file tree

Hide file tree

Showing 7 changed files with 5 additions and 5 deletions.
diff --git a/streamable/_stream.py b/streamable/_stream.py
@@ -26,7 +26,7 @@
 if TYPE_CHECKING:
     import builtins
 
-    from streamable._visitors._base import Visitor
+    from streamable._visitors._visitor import Visitor
 
 U = TypeVar("U")
 T = TypeVar("T")

diff --git a/streamable/_visitors/_explanation.py b/streamable/_visitors/_explanation.py
@@ -1,7 +1,7 @@
 from typing import Any
 
 from streamable import _stream, _util
-from streamable._visitors._base import Visitor
+from streamable._visitors._visitor import Visitor
 
 
 class ExplainingVisitor(Visitor[str]):

diff --git a/streamable/_visitors/_iteration.py b/streamable/_visitors/_iteration.py
@@ -2,7 +2,7 @@
 from typing import Iterable, Iterator, List, TypeVar, cast
 
 from streamable import _stream, _util, functions
-from streamable._visitors._base import Visitor
+from streamable._visitors._visitor import Visitor
 
 T = TypeVar("T")
 U = TypeVar("U")

diff --git a/streamable/_visitors/_base.py → streamable/_visitors/_visitor.py b/streamable/_visitors/_base.py → streamable/_visitors/_visitor.py
diff --git a/streamable/functions/__init__.py b/streamable/functions/__init__.py
@@ -1 +1 @@
-from streamable.functions._itertools import batch, catch, flatten, map, observe, slow
+from streamable.functions._functions import batch, catch, flatten, map, observe, slow
diff --git a/streamable/functions/_itertools.py → streamable/functions/_functions.py b/streamable/functions/_itertools.py → streamable/functions/_functions.py
diff --git a/tests/test_stream.py b/tests/test_stream.py
@@ -363,7 +363,7 @@ def __iter__(self) -> Iterator[int]:
     def test_partial_iteration_on_streams_using_concurrency(
         self, concurrency: int
     ) -> None:
-        from streamable.functions._itertools import _CONCURRENCY_BUFFER_SIZE_FACTOR
+        from streamable.functions._functions import _CONCURRENCY_BUFFER_SIZE_FACTOR
 
         yielded_elems = []
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		from streamable.functions._itertools import batch, catch, flatten, map, observe, slow
		from streamable.functions._functions import batch, catch, flatten, map, observe, slow