@@ -19,14 +19,14 @@ def exhaust(gen: Iterable[T]) -> None:
19
19
20
20
@contextlib .contextmanager
21
21
def _in_process () -> Generator [
22
- Callable [[Callable [[T2 ], T ], Iterable [T2 ]], Iterable [T ]], None , None ,
22
+ Callable [[Callable [[T2 ], T ], Iterable [T2 ]], Iterable [T ]],
23
23
]:
24
24
yield map
25
25
26
26
27
27
@contextlib .contextmanager
28
28
def _threads (jobs : int ) -> Generator [
29
- Callable [[Callable [[T2 ], T ], Iterable [T2 ]], Iterable [T ]], None , None ,
29
+ Callable [[Callable [[T2 ], T ], Iterable [T2 ]], Iterable [T ]],
30
30
]:
31
31
with concurrent .futures .ThreadPoolExecutor (jobs ) as ex :
32
32
yield ex .map
@@ -43,7 +43,7 @@ def thread_mapper(jobs: int) -> ContextManager[
43
43
44
44
@contextlib .contextmanager
45
45
def _processes (jobs : int ) -> Generator [
46
- Callable [[Callable [[T2 ], T ], Iterable [T2 ]], Iterable [T ]], None , None ,
46
+ Callable [[Callable [[T2 ], T ], Iterable [T2 ]], Iterable [T ]],
47
47
]:
48
48
with concurrent .futures .ProcessPoolExecutor (jobs ) as ex :
49
49
yield ex .map
0 commit comments