diff options
Diffstat (limited to 'gr-zeromq/python/zeromq/qa_zeromq_sub.py')
-rwxr-xr-x | gr-zeromq/python/zeromq/qa_zeromq_sub.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_sub.py b/gr-zeromq/python/zeromq/qa_zeromq_sub.py index f916901ff7..d6006780dc 100755 --- a/gr-zeromq/python/zeromq/qa_zeromq_sub.py +++ b/gr-zeromq/python/zeromq/qa_zeromq_sub.py @@ -44,7 +44,7 @@ class qa_zeromq_sub (gr_unittest.TestCase): def test_001 (self): vlen = 10 - src_data = numpy.array(range(vlen)*100, 'float32') + src_data = numpy.array(range(vlen), 'float32')*100 zeromq_sub_source = zeromq.sub_source(gr.sizeof_float, vlen, "tcp://127.0.0.1:5555") sink = blocks.vector_sink_f(vlen) self.tb.connect(zeromq_sub_source, sink) @@ -60,7 +60,7 @@ class qa_zeromq_sub (gr_unittest.TestCase): vlen = 10 # Construct multipart source data to publish - raw_data = [numpy.array(range(vlen)*100, 'float32'), numpy.array(range(vlen, 2*vlen)*100, 'float32')] + raw_data = [numpy.array(range(vlen), 'float32')*100, numpy.array(range(vlen, 2*vlen), 'float32')*100] src_data = [a.tostring() for a in raw_data] zeromq_sub_source = zeromq.sub_source(gr.sizeof_float, vlen, "tcp://127.0.0.1:5555") sink = blocks.vector_sink_f(vlen) |