From 9970854f8938fcc015608dc163442467427cb9a6 Mon Sep 17 00:00:00 2001
From: Camilo Solano <solano@ti.rwth-aachen.de>
Date: Tue, 13 May 2014 12:53:23 +0200
Subject: Add sub_source block and fix pub_sink
---
gr-zeromq/examples/python/server.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
(limited to 'gr-zeromq/examples/python/server.py')
diff --git a/gr-zeromq/examples/python/server.py b/gr-zeromq/examples/python/server.py
index 28b732ed3e..358b66c568 100755
--- a/gr-zeromq/examples/python/server.py
+++ b/gr-zeromq/examples/python/server.py
@@ -56,7 +56,8 @@ class top_block(gr.top_block):
self.gr_sig_source = analog.sig_source_f(samp_rate, analog.GR_SIN_WAVE , 1000, 1, 0)
self.throttle = blocks.throttle(gr.sizeof_float, samp_rate)
self.mult = blocks.multiply_const_ff(1)
- self.zmq_sink = zeromq.rep_sink(gr.sizeof_float, 1, sink_adr)
+ #self.zmq_sink = zeromq.rep_sink(gr.sizeof_float, 1, sink_adr)
+ self.zmq_sink = zeromq.pub_sink(gr.sizeof_float, 1, sink_adr)
#self.zmq_sink = zeromq.push_sink(gr.sizeof_float, 1, sink_adr)
#self.zmq_probe = zeromq.push_sink(gr.sizeof_float, probe_adr)
self.zmq_probe = zeromq.pub_sink(gr.sizeof_float, probe_adr)
--
cgit v1.2.3