diff --git a/aiomultiprocess/pool.py b/aiomultiprocess/pool.py index 93e7603..251711a 100644 --- a/aiomultiprocess/pool.py +++ b/aiomultiprocess/pool.py @@ -14,6 +14,7 @@ Callable, Dict, Generator, + Iterable, Optional, Sequence, Tuple, @@ -333,7 +334,7 @@ async def apply( def map( self, func: Callable[[T], Awaitable[R]], - iterable: Sequence[T], + iterable: Iterable[T], # chunksize: int = None, # todo: implement chunking maybe ) -> PoolResult[R]: """Run a coroutine once for each item in the iterable."""