(
        self,
        func: Callable[[T], Awaitable[R]],
        iterable: Sequence[T],
        # chunksize: int = None,  # todo: implement chunking maybe
    )
return PoolResult(self, tids)
Run a coroutine once for each item in the iterable.
Run a coroutine once for each item in the iterable.
Run a coroutine once for each item in the iterable .
def map(
        self,
        func: Callable[[T], Awaitable[R]],
        iterable: Sequence[T],
        # chunksize: int = None,  # todo: implement chunking maybe
    ) -> PoolResult[R]:
        """Run a coroutine once for each item in the iterable."""
        if not self.running:
            raise RuntimeError("pool is closed")

        tids = [self.queue_work(func, (item,), {}) for item in iterable]
        return PoolResult(self, tids)
def map ( self , func : Callable [ [ T ] , Awaitable [ R ] ] , iterable : Sequence [ T ] , # chunksize: int = None,  # todo: implement chunking maybe ) -> PoolResult [ R ] : if not self . running : raise RuntimeError ( "pool is closed" ) tids = [ self . queue_work ( func , ( item , ) , { } ) for item in iterable ] return PoolResult ( self , tids )