fix: rm AnyAwaitable

src/timeout_executor/executor.py

@@ -15,7 +15,7 @@
 
 import anyio
 import cloudpickle
-from typing_extensions import ParamSpec, Self, TypeAlias, TypeVar, override
+from typing_extensions import ParamSpec, Self, TypeVar, override
 
 from timeout_executor.const import SUBPROCESS_COMMAND, TIMEOUT_EXECUTOR_INPUT_FILE
 from timeout_executor.logging import logger
@@ -24,7 +24,7 @@
 from timeout_executor.types import Callback, CallbackArgs, ExecutorArgs, ProcessCallback
 
 if TYPE_CHECKING:
-    from collections.abc import Awaitable, Coroutine, Iterable
+    from collections.abc import Awaitable, Iterable
 
     from timeout_executor.main import TimeoutExecutor
 
@@ -34,7 +34,6 @@
 T = TypeVar("T", infer_variance=True)
 P2 = ParamSpec("P2")
 T2 = TypeVar("T2", infer_variance=True)
-AnyAwaitable: TypeAlias = "Awaitable[T] | Coroutine[Any, Any, T]"
 
 
 class Executor(Callback[P, T], Generic[P, T]):
@@ -202,7 +201,7 @@ def remove_callback(self, callback: ProcessCallback[P, T]) -> Self:
 @overload
 def apply_func(
     timeout_or_executor: float | TimeoutExecutor,
-    func: Callable[P2, AnyAwaitable[T2]],
+    func: Callable[P2, Awaitable[T2]],
     *args: P2.args,
     **kwargs: P2.kwargs,
 ) -> AsyncResult[P2, T2]: ...
@@ -246,7 +245,7 @@ def apply_func(
 @overload
 async def delay_func(
     timeout_or_executor: float | TimeoutExecutor,
-    func: Callable[P2, AnyAwaitable[T2]],
+    func: Callable[P2, Awaitable[T2]],
     *args: P2.args,
     **kwargs: P2.kwargs,
 ) -> AsyncResult[P2, T2]: ...

src/timeout_executor/main.py

@@ -4,13 +4,13 @@
 from contextlib import suppress
 from typing import TYPE_CHECKING, Any, Callable, Generic, overload
 
-from typing_extensions import ParamSpec, Self, TypeAlias, TypeVar, override
+from typing_extensions import ParamSpec, Self, TypeVar, override
 
 from timeout_executor.executor import apply_func, delay_func
 from timeout_executor.types import Callback, ProcessCallback
 
 if TYPE_CHECKING:
-    from collections.abc import Awaitable, Coroutine, Iterable
+    from collections.abc import Awaitable, Iterable
 
     from timeout_executor.result import AsyncResult
 
@@ -19,7 +19,6 @@
 P = ParamSpec("P")
 T = TypeVar("T", infer_variance=True)
 AnyT = TypeVar("AnyT", infer_variance=True, default=Any)
-AnyAwaitable: TypeAlias = "Awaitable[T] | Coroutine[Any, Any, T]"
 
 
 class TimeoutExecutor(Callback[Any, AnyT], Generic[AnyT]):
@@ -36,7 +35,7 @@ def timeout(self) -> float:
 
     @overload
     def apply(
-        self, func: Callable[P, AnyAwaitable[T]], *args: P.args, **kwargs: P.kwargs
+        self, func: Callable[P, Awaitable[T]], *args: P.args, **kwargs: P.kwargs
     ) -> AsyncResult[P, T]: ...
     @overload
     def apply(
@@ -59,7 +58,7 @@ def apply(
 
     @overload
     async def delay(
-        self, func: Callable[P, AnyAwaitable[T]], *args: P.args, **kwargs: P.kwargs
+        self, func: Callable[P, Awaitable[T]], *args: P.args, **kwargs: P.kwargs
     ) -> AsyncResult[P, T]: ...
     @overload
     async def delay(
@@ -82,7 +81,7 @@ async def delay(
 
     @overload
     async def apply_async(
-        self, func: Callable[P, AnyAwaitable[T]], *args: P.args, **kwargs: P.kwargs
+        self, func: Callable[P, Awaitable[T]], *args: P.args, **kwargs: P.kwargs
     ) -> AsyncResult[P, T]: ...
     @overload
     async def apply_async(

src/timeout_executor/subprocess.py

@@ -2,7 +2,7 @@
 
 from __future__ import annotations
 
-from collections.abc import Awaitable, Coroutine
+from collections.abc import Awaitable
 from os import environ
 from pathlib import Path
 from typing import TYPE_CHECKING, Any, Callable
@@ -12,11 +12,10 @@
 from timeout_executor.const import TIMEOUT_EXECUTOR_INPUT_FILE
 
 if TYPE_CHECKING:
-    from typing_extensions import ParamSpec, TypeAlias, TypeVar
+    from typing_extensions import ParamSpec, TypeVar
 
     P = ParamSpec("P")
     T = TypeVar("T", infer_variance=True)
-    AnyAwaitable: TypeAlias = "Awaitable[T] | Coroutine[Any, Any, T]"
 
 __all__ = []