fix auth module data losing

1 files changed, 1 insertions, 12 deletions

diff --git a/pkg/server/socket/socket.go b/pkg/server/socket/socket.go
index 48a650c..3db4310 100644
--- a/pkg/server/socket/socket.go
+++ b/pkg/server/socket/socket.go
@@ -47,18 +47,7 @@ func (cc *connChannel) Send(wq queue.Q) (err error) {
 
 func (cc *connChannel) Recv(rq queue.Q) (err error) {
 	defer cc.shutdown(&err)
-
-	for b := range rq {
-		for len(b) > 0 {
-			n, err := cc.conn.Write(b)
-			if err != nil {
-				return err
-			}
-			b = b[n:]
-		}
-	}
-
-	return nil
+	return queue.IoCopy(rq.Reader(), cc.conn)
 }
 
 func (cc *connChannel) String() string {