black .

remove seconds empty line at EOF

aiostream/aiter_utils.py

@@ -207,7 +207,9 @@ async def __aexit__(
                         await self._aiterator.athrow(value)
                     else:
                         await self._aiterator.athrow(typ, value, traceback)
-                    raise RuntimeError("Async iterator didn't stop after athrow()")
+                    raise RuntimeError(
+                        "Async iterator didn't stop after athrow()"
+                    )
 
                 # Exception has been (most probably) silenced
                 except StopAsyncIteration as exc:

aiostream/test_utils.py

@@ -145,7 +145,9 @@ def _run_once(self) -> None:
         super()._run_once()
         # Update internals
         self.busy_count += 1
-        self._timers = sorted(when for when in self._timers if when > self.time())
+        self._timers = sorted(
+            when for when in self._timers if when > self.time()
+        )
         # Time advance
         if self.time_to_go:
             when = self._timers.pop(0)

pyproject.toml

@@ -4,4 +4,3 @@ ignore = ["aiostream/test_utils.py"]
 [tool.black]
 line-length = 80
 target_version = ["py38", "py39", "py310", "py311", "py312"]
-

tests/test_advanced.py

@@ -13,7 +13,11 @@ def target2(x: int, *_) -> Stream[int]:
         return stream.range(x, x + 4, interval=1)
 
     def target3(x: int, *_) -> Stream[int]:
-        return stream.range(0, 3, interval=1) if x else stream.throw(ZeroDivisionError)
+        return (
+            stream.range(0, 3, interval=1)
+            if x
+            else stream.throw(ZeroDivisionError)
+        )
 
     # Concurrent run
     with assert_cleanup() as loop:

tests/test_select.py

@@ -159,7 +159,11 @@ async def afunc(x):
 @pytest.mark.asyncio
 async def test_until(assert_run, assert_cleanup):
     with assert_cleanup():
-        xs = stream.range(1, 10) | add_resource.pipe(1) | pipe.until(lambda x: x == 3)
+        xs = (
+            stream.range(1, 10)
+            | add_resource.pipe(1)
+            | pipe.until(lambda x: x == 3)
+        )
         await assert_run(xs, [1, 2, 3])
 
     async def afunc(x):
@@ -178,7 +182,11 @@ def less_than_4(x: int) -> bool:
         return x < 4
 
     with assert_cleanup():
-        xs = stream.range(1, 10) | add_resource.pipe(1) | pipe.takewhile(less_than_4)
+        xs = (
+            stream.range(1, 10)
+            | add_resource.pipe(1)
+            | pipe.takewhile(less_than_4)
+        )
         await assert_run(xs, [1, 2, 3])
 
     async def afunc(x):
@@ -197,7 +205,11 @@ def less_than_7(x: int) -> bool:
         return x < 7
 
     with assert_cleanup():
-        xs = stream.range(1, 10) | add_resource.pipe(1) | pipe.dropwhile(less_than_7)
+        xs = (
+            stream.range(1, 10)
+            | add_resource.pipe(1)
+            | pipe.dropwhile(less_than_7)
+        )
         await assert_run(xs, [7, 8, 9])
 
     async def afunc(x):

tests/test_transform.py

@@ -42,7 +42,12 @@ async def test_cycle(assert_run, assert_cleanup):
         await assert_run(xs, [], asyncio.TimeoutError())
 
     with assert_cleanup():
-        xs = stream.empty() | add_resource.pipe(1) | pipe.cycle() | pipe.timeout(1)
+        xs = (
+            stream.empty()
+            | add_resource.pipe(1)
+            | pipe.cycle()
+            | pipe.timeout(1)
+        )
         await assert_run(xs, [], asyncio.TimeoutError())
 
     with assert_cleanup() as loop: