diff options
| author | Johnathan Corgan <johnathan@corganlabs.com> | 2017-04-06 21:25:51 -0700 |
|---|---|---|
| committer | Johnathan Corgan <johnathan@corganlabs.com> | 2017-04-06 21:25:51 -0700 |
| commit | ca38efec194f7d4e437a294838268a2ccdf609e9 (patch) | |
| tree | 74237271f5ff456f69dcbf608b4d65543d16064e /gr-zeromq/python/zeromq/qa_zeromq_pub.py | |
| parent | 83526c6c7c16c483f42bee4d4602c2b9f88258cc (diff) | |
| parent | 42fa660d84398b0b06908948e2064b711d72da3f (diff) | |
Merge branch 'next' into python3
Diffstat (limited to 'gr-zeromq/python/zeromq/qa_zeromq_pub.py')
| -rw-r--r-- | gr-zeromq/python/zeromq/qa_zeromq_pub.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_pub.py b/gr-zeromq/python/zeromq/qa_zeromq_pub.py index 1bf3263747..2cee710d2a 100644 --- a/gr-zeromq/python/zeromq/qa_zeromq_pub.py +++ b/gr-zeromq/python/zeromq/qa_zeromq_pub.py @@ -25,6 +25,7 @@ from gnuradio import gr, gr_unittest from gnuradio import blocks, zeromq from gnuradio import eng_notation +import threading class qa_zeromq_pub (gr_unittest.TestCase): @@ -43,8 +44,11 @@ class qa_zeromq_pub (gr_unittest.TestCase): self.tb.connect(src, zeromq_pub_sink) self.probe_manager = zeromq.probe_manager() self.probe_manager.add_socket("tcp://127.0.0.1:5555", 'float32', self.recv_data) + zmq_pull_t = threading.Thread(target=self.probe_manager.watcher) + zmq_pull_t.daemon = True + zmq_pull_t.start() self.tb.run() - self.probe_manager.watcher() + zmq_pull_t.join() self.assertFloatTuplesAlmostEqual(self.rx_data, src_data) def recv_data (self, data): |