diff --git a/lib/conn/snappy.go b/lib/conn/snappy.go index 7ee0619..cfd33c4 100644 --- a/lib/conn/snappy.go +++ b/lib/conn/snappy.go @@ -3,7 +3,6 @@ package conn import ( "github.com/cnlh/nps/lib/pool" "github.com/cnlh/nps/vender/github.com/golang/snappy" - "github.com/fatedier/frp/utils/net" "io" ) @@ -12,7 +11,7 @@ type SnappyConn struct { r *snappy.Reader } -func NewSnappyConn(conn io.ReadWriteCloser) net.Conn { +func NewSnappyConn(conn io.ReadWriteCloser) *SnappyConn { c := new(SnappyConn) c.w = snappy.NewBufferedWriter(conn) c.r = snappy.NewReader(conn) diff --git a/lib/rate/conn.go b/lib/rate/conn.go index 06856b9..7e4ef01 100644 --- a/lib/rate/conn.go +++ b/lib/rate/conn.go @@ -2,15 +2,14 @@ package rate import ( "io" - "net" ) type rateConn struct { - conn net.Conn + conn io.ReadWriteCloser rate *Rate } -func NewRateConn(conn net.Conn, rate *Rate) io.ReadWriteCloser { +func NewRateConn(conn io.ReadWriteCloser, rate *Rate) io.ReadWriteCloser { return &rateConn{ conn: conn, rate: rate,