diff options
Diffstat (limited to 'src/gr-fadingui/python/dearpygui_sink.py')
-rw-r--r-- | src/gr-fadingui/python/dearpygui_sink.py | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/src/gr-fadingui/python/dearpygui_sink.py b/src/gr-fadingui/python/dearpygui_sink.py index 2b8e9fb..353f2d9 100644 --- a/src/gr-fadingui/python/dearpygui_sink.py +++ b/src/gr-fadingui/python/dearpygui_sink.py @@ -19,6 +19,8 @@ # Boston, MA 02110-1301, USA. # +import socket +from urllib.parse import urlparse import numpy as np from gnuradio import gr @@ -27,15 +29,24 @@ class dearpygui_sink(gr.sync_block): """ docstring for block dearpygui_sink """ - def __init__(self): + def __init__(self, sock_addr, ui_element_id): gr.sync_block.__init__(self, name="dearpygui_sink", in_sig=[np.complex64], out_sig=None) + # sockets + self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) + self.srv = urlparse(sock_addr) + + def send(self, value): + data = bytes(repr(value), "ascii") + sent = self.socket.sendto(data, (self.srv.hostname, self.srv.port)) + + return len(data) == sent def work(self, input_items, output_items): in0 = input_items[0] - # <+signal processing here+> + self.send(in0) return len(input_items[0]) |