lint

ebonnal · Dec 25, 2023 · 9516e7b · 9516e7b
1 parent 0868905
commit 9516e7b
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/streamable/_stream.py b/streamable/_stream.py
@@ -191,7 +191,9 @@ def filter(self, predicate: Callable[[T], bool]) -> "Stream[T]":
         """
         return FilterStream(self, predicate)
 
-    def batch(self, size: int = 100, seconds: float = float("inf")) -> "Stream[List[T]]":
+    def batch(
+        self, size: int = 100, seconds: float = float("inf")
+    ) -> "Stream[List[T]]":
         """
         Batch elements of the Stream into lists of a specified size or within a specified time window.
 

diff --git a/streamable/_visit/_explanation.py b/streamable/_visit/_explanation.py
@@ -79,7 +79,9 @@ def visit_do_stream(self, stream: _stream.DoStream) -> Any:
 
     def visit_flatten_stream(self, stream: _stream.FlattenStream) -> Any:
         name = "Flatten"
-        descr = f"using {stream.concurrency} thread{'s' if stream.concurrency > 1 else ''}"
+        descr = (
+            f"using {stream.concurrency} thread{'s' if stream.concurrency > 1 else ''}"
+        )
         return self.visit_any_stream(stream, name, descr)
 
     def visit_filter_stream(self, stream: _stream.FilterStream) -> Any:

diff --git a/streamable/_visit/_iter.py b/streamable/_visit/_iter.py
@@ -65,7 +65,9 @@ def visit_batch_stream(self, stream: _stream.BatchStream[U]) -> Iterator[T]:
         )
 
     def visit_slow_stream(self, stream: _stream.SlowStream[T]) -> Iterator[T]:
-        return _core.SlowingIteratorWrapper(stream.upstream._accept(self), stream.frequency)
+        return _core.SlowingIteratorWrapper(
+            stream.upstream._accept(self), stream.frequency
+        )
 
     def visit_catch_stream(self, stream: _stream.CatchStream[T]) -> Iterator[T]:
         if stream.when is not None: