close.

IQTLabs · Jun 23, 2024 · 080442d · 080442d
1 parent 734a493
commit 080442d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/gamutrf/grpduzmq.py b/gamutrf/grpduzmq.py
@@ -35,6 +35,9 @@ def __init__(
         self.message_port_register_in(pmt.intern("json"))
         self.set_msg_handler(pmt.intern("json"), self.receive_pdu)
 
+    def stop(self):
+        self.zmq_pub.close()
+
     def receive_pdu(self, pdu):
         item = pmt.to_python(pmt.cdr(pdu)).tobytes().decode("utf8").strip()
         self.zmq_pub.send_string(item + DELIM, flags=zmq.NOBLOCK)