diff --git a/requests/async.py b/requests/async.py index fafcb9ed..94884478 100644 --- a/requests/async.py +++ b/requests/async.py @@ -78,12 +78,8 @@ def map(requests, prefetch=True, size=None): requests = list(requests) - if size: - pool = Pool(size) - jobs = [pool.spawn(r.send) for r in requests] - else: - jobs = [gevent.spawn(r.send) for r in requests] - + pool = Pool(size) if size else None + jobs = [send(r, pool) for r in requests] gevent.joinall(jobs) if prefetch: