nng.go
@@ -33,6 +33,9 @@ // Send impl interface Diliver func (n *NNG) Send(data []byte) error { if n == nil { return errors.New("please init NNG first") } var err error if n.sock == nil { n.sock, err = n.makeNNG(agent) @@ -54,6 +57,10 @@ // Recv impl interface Diliver func (n *NNG) Recv() ([]byte, error) { if n == nil { return nil, errors.New("please init NNG first") } var err error if n.sock == nil { @@ -74,7 +81,7 @@ // Close impl interface Deliver func (n *NNG) Close() { if n.sock != nil { if n != nil && n.sock != nil { n.sock.Close() n.sock = nil }