From fa924718b1e8d5f566f7655807e77df1bcfe8f86 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期二, 27 八月 2019 14:41:54 +0800 Subject: [PATCH] add recv2 return len --- nng.go | 8 +++++++- 1 files changed, 7 insertions(+), 1 deletions(-) diff --git a/nng.go b/nng.go index fa3e409..fe82e3d 100644 --- a/nng.go +++ b/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) -- Gitblit v1.8.0