server.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
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