-
- cmd_chans, pub_chans := ZmqsInit("tcp://localhost:5555", "gmp://*:6666")
-
- serial_wr, serial_rd, err := OpenAndHandleSerial(args[0], pub_chans.Out())
+
+ zmqctx, cmd_chans, pub_chans := ZmqsInit(cmd_port_, pub_port_)
+ defer cmd_chans.Close()
+ defer pub_chans.Close()
+ defer zmqctx.Close()
+
+ serial_wr, err := OpenAndHandleSerial(args[0], pub_chans.Out())
+ defer close(serial_wr)