From 3873121c01d0081777edb49b90d00e4c0ae777e1 Mon Sep 17 00:00:00 2001 From: Piotr Dobrogost Date: Fri, 20 Jan 2012 21:42:25 +0100 Subject: [PATCH] tiny map() refactoring --- requests/async.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/requests/async.py b/requests/async.py index fafcb9e..9488447 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: -- 2.7.4