zhangmeng
2019-08-27 fa924718b1e8d5f566f7655807e77df1bcfe8f86
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)