-func zmqsHandleError(cmd_chans, sub_chans *zmq.Channels) {
- for {
- select {
- case cmd_error := <- cmd_chans.Errors():
- cmd_chans.Close()
- sub_chans.Close()
- panic(cmd_error)
- case sub_error := <- sub_chans.Errors():
- cmd_chans.Close()
- sub_chans.Close()
- panic(sub_error)
- }