Refactor pathoc message receive to use queues and generators

This gives us a nicer, thread-safe interface.

1 files changed, 6 insertions, 3 deletions

diff --git a/test/tutils.py b/test/tutils.py
index dc118bbe..1e33dfe7 100644
--- a/test/tutils.py
+++ b/test/tutils.py
@@ -88,9 +88,12 @@ class DaemonTests(object):
             c.settimeout(timeout)
         ret = []
         for i in specs:
-            ret.append(c.request(i))
-        return ret
-
+            resp = c.request(i)
+            if resp:
+                ret.append(resp)
+        for frm in c.wait():
+            ret.append(frm)
+        return ret 
 
 @contextmanager
 def tmpdir(*args, **kwargs):