Allow generators or any iterators for async.map

2026-06-05 22:50:18 +00:00 · 2011-11-25 07:45:12 +05:30
parent 9d8d1d14f1
commit 99b6e35940
1 changed files with 2 additions and 0 deletions
@@ -71,6 +71,8 @@ def map(requests, prefetch=True, size=None):
    :param size: Specifies the number of requests to make at a time. If None, no throttling occurs.
    """

+    requests = list(requests)
+
    if size:
        pool = Pool(size)
        pool.map(send, requests)