Add GetMonitorSocket go equivalent to pyzmq get_monitor_socket

Author: clintlombard

draft/zmq4.go

@@ -1354,6 +1354,30 @@ func (soc *Socket) Monitor(addr string, events Event) error {
 	return nil
 }
 
+/*
+Return a connected PAIR socket ready to receive the event notifications.
+*/
+func GetMonitorSocket(sock *Socket, events Event) (monitor_sock *Socket, err error) {
+	fd, err := sock.GetFd()
+	if err != nil {
+		return
+	}
+	addr := fmt.Sprintf("inproc://monitor.s-%d", fd)
+	err = sock.Monitor(addr, events)
+	if err != nil {
+		return
+	}
+	monitor_sock, err = NewSocket(PAIR)
+	if err != nil {
+		return
+	}
+	err = monitor_sock.Connect(addr)
+	if err != nil {
+		return
+	}
+	return
+}
+
 /*
 Receive a message part from a socket interpreted as an event.
 

zmq4.go

@@ -1230,6 +1230,30 @@ func (soc *Socket) Monitor(addr string, events Event) error {
 	return nil
 }
 
+/*
+Return a connected PAIR socket ready to receive the event notifications.
+*/
+func GetMonitorSocket(sock *Socket, events Event) (monitor_sock *Socket, err error) {
+	fd, err := sock.GetFd()
+	if err != nil {
+		return
+	}
+	addr := fmt.Sprintf("inproc://monitor.s-%d", fd)
+	err = sock.Monitor(addr, events)
+	if err != nil {
+		return
+	}
+	monitor_sock, err = NewSocket(PAIR)
+	if err != nil {
+		return
+	}
+	err = monitor_sock.Connect(addr)
+	if err != nil {
+		return
+	}
+	return
+}
+
 /*
 Receive a message part from a socket interpreted as an event.