rework multibuf copy

transport/internet/kcp/connection.go

@@ -392,7 +392,11 @@ func (c *Connection) WriteMultiBuffer(mb buf.MultiBuffer) error {
 		}
 	}()
 
-	mbPtr := &mb
+	f := func(x *buf.MultiBuffer) buf.Supplier {
+		return func(bb []byte) (int, error) {
+			return x.Read(bb[:c.mss])
+		}
+	}(&mb)
 
 	for {
 		for {
@@ -400,13 +404,11 @@ func (c *Connection) WriteMultiBuffer(mb buf.MultiBuffer) error {
 				return io.ErrClosedPipe
 			}
 
-			if !c.sendingWorker.Push(func(bb []byte) (int, error) {
+			if !c.sendingWorker.Push(f) {
-				return mbPtr.Read(bb[:c.mss])
-			}) {
 				break
 			}
 			updatePending = true
-			if mbPtr.IsEmpty() {
+			if mb.IsEmpty() {
 				return nil
 			}
 		}