black24

Author: maxfischer2781

asyncstdlib/__init__.py

@@ -1,4 +1,5 @@
 """The missing async toolbox"""
+
 from .builtins import (
     anext,
     zip,

asyncstdlib/_core.py

@@ -7,6 +7,7 @@
 Any helpers in this module are *not* bound to maintaining a public interface,
 and offer less convenience to save on overhead.
 """
+
 from inspect import iscoroutinefunction
 from typing import (
     Any,

asyncstdlib/_lrucache.py

@@ -5,6 +5,7 @@
 several performance hacks are skipped in favour of maintainability,
 especially when they might not apply to PyPy.
 """
+
 from typing import (
     NamedTuple,
     Callable,
@@ -154,15 +155,13 @@ def __annotations__(self) -> Dict[str, Any]:  # type: ignore
 
 
 @overload
-def lru_cache(maxsize: AC, typed: bool = ...) -> LRUAsyncCallable[AC]:
-    ...
+def lru_cache(maxsize: AC, typed: bool = ...) -> LRUAsyncCallable[AC]: ...
 
 
 @overload
 def lru_cache(
     maxsize: Optional[int] = ..., typed: bool = ...
-) -> Callable[[AC], LRUAsyncCallable[AC]]:
-    ...
+) -> Callable[[AC], LRUAsyncCallable[AC]]: ...
 
 
 @public_module("asyncstdlib.functools")

asyncstdlib/_typing.py

@@ -4,6 +4,7 @@
 This module is for internal use only. Do *not* put any new
 "async typing" definitions here.
 """
+
 from typing import (
     TypeVar,
     Hashable,

asyncstdlib/asynctools.py

@@ -222,8 +222,7 @@ async def apply(
     __func: Callable[[T1], T],
     __arg1: Awaitable[T1],
     /,
-) -> T:
-    ...
+) -> T: ...
 
 
 @overload
@@ -232,8 +231,7 @@ async def apply(
     __arg1: Awaitable[T1],
     __arg2: Awaitable[T2],
     /,
-) -> T:
-    ...
+) -> T: ...
 
 
 @overload
@@ -243,8 +241,7 @@ async def apply(
     __arg2: Awaitable[T2],
     __arg3: Awaitable[T3],
     /,
-) -> T:
-    ...
+) -> T: ...
 
 
 @overload
@@ -255,8 +252,7 @@ async def apply(
     __arg3: Awaitable[T3],
     __arg4: Awaitable[T4],
     /,
-) -> T:
-    ...
+) -> T: ...
 
 
 @overload
@@ -268,8 +264,7 @@ async def apply(
     __arg4: Awaitable[T4],
     __arg5: Awaitable[T5],
     /,
-) -> T:
-    ...
+) -> T: ...
 
 
 @overload
@@ -278,8 +273,7 @@ async def apply(
     /,
     *args: Awaitable[Any],
     **kwargs: Awaitable[Any],
-) -> T:
-    ...
+) -> T: ...
 
 
 async def apply(
@@ -313,13 +307,11 @@ async def compute_something_else() -> float:
 
 
 @overload
-def sync(function: Callable[..., Awaitable[T]], /) -> Callable[..., Awaitable[T]]:
-    ...
+def sync(function: Callable[..., Awaitable[T]], /) -> Callable[..., Awaitable[T]]: ...
 
 
 @overload
-def sync(function: Callable[..., T], /) -> Callable[..., Awaitable[T]]:
-    ...
+def sync(function: Callable[..., T], /) -> Callable[..., Awaitable[T]]: ...
 
 
 def sync(function: Callable[..., Any], /) -> Callable[..., Any]:
@@ -415,11 +407,11 @@ async def await_iter(n):
     iterable = __iter if not isinstance(__iter, Awaitable) else await __iter
     if isinstance(iterable, AsyncIterable):
         async for item in iterable:
-            yield item if not isinstance(
-                item, Awaitable
-            ) else await item  # pyright: ignore[reportGeneralTypeIssues]
+            yield (
+                item if not isinstance(item, Awaitable) else await item
+            )  # pyright: ignore[reportGeneralTypeIssues]
     else:
         for item in iterable:
-            yield item if not isinstance(
-                item, Awaitable
-            ) else await item  # pyright: ignore[reportGeneralTypeIssues]
+            yield (
+                item if not isinstance(item, Awaitable) else await item
+            )  # pyright: ignore[reportGeneralTypeIssues]