diff --git a/eventlet/proc.py b/eventlet/proc.py index 724888b..4c00eea 100644 --- a/eventlet/proc.py +++ b/eventlet/proc.py @@ -168,8 +168,9 @@ class LinkToCallable(Link): self.listener(source) -def waitall(lst, trap_errors=False): - queue = coros.queue() +def waitall(lst, trap_errors=False, queue=None): + if queue is None: + queue = coros.queue() index = -1 for (index, linkable) in enumerate(lst): linkable.link(decorate_send(queue, index))