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