diff options
Diffstat (limited to 'pkg/server/socket')
| -rw-r--r-- | pkg/server/socket/socket.go | 13 |
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 { |