nng.go
@@ -79,6 +79,12 @@ } // Recv2 impl interface func (n *NNG) Recv2(data []byte) (l int, err error) { data, err = n.Recv() return len(data), err } // Close impl interface Deliver func (n *NNG) Close() { if n != nil && n.sock != nil { @@ -127,7 +133,7 @@ switch n.mode { case Bus: sock, err = n.busMakeNNG(typ) case ReqRep: case ReqRep, SurvResp: sock, err = n.rrMakeNNG(typ) default: sock, err = n.ppMakeNNG(typ)