server.go @@ -149,6 +149,7 @@ responses = NewStringSet() for { msg, err = d.sock.Recv() d.PublishMsg("Init") if err != nil { if err == mangos.ErrRecvTimeout { // Timeout means I can add the current responses to the SET