un-export newBufConn

broker.go

@@ -85,7 +85,7 @@ func (b *Broker) Open(conf *Config) error {
 			Logger.Printf("Failed to connect to broker %s: %s\n", b.addr, b.connErr)
 			return
 		}
-		b.conn = NewBufConn(b.conn)
+		b.conn = newBufConn(b.conn)
 
 		b.conf = conf
 		b.done = make(chan bool)

utils.go

@@ -99,7 +99,7 @@ type bufConn struct {
 	buf *bufio.Reader
 }
 
-func NewBufConn(conn net.Conn) *bufConn {
+func newBufConn(conn net.Conn) *bufConn {
 	return &bufConn{
 		Conn: conn,
 		buf:  bufio.NewReader(conn),