proc: optionally accept queue as a parameter in waitall() function

2009-04-24 18:15:39 +07:00
parent 7c2db57ccf
commit c8d9f6ea56
1 changed files with 3 additions and 2 deletions
--- a/eventlet/proc.py
+++ b/eventlet/proc.py
@@ -168,7 +168,8 @@ class LinkToCallable(Link):
        self.listener(source)


-def waitall(lst, trap_errors=False):
+def waitall(lst, trap_errors=False, queue=None):
+    if queue is None:
        queue = coros.queue()
    index = -1
    for (index, linkable) in enumerate(lst):