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