When timeout no longer needs to be enforced, no need to schedule a broadcast.

internal/multiplex/datagramBufferedPipe.go

@@ -105,7 +105,7 @@ func (d *datagramBufferedPipe) WriteTo(w io.Writer) (n int64, err error) {
 				if !d.rDeadline.IsZero() {
 					d.broadcastAfter(time.Until(d.rDeadline))
 				}
-			} else {
+			} else if enforceTimeout {
 				d.broadcastAfter(d.wtTimeout)
 			}
 

internal/multiplex/streamBufferedPipe.go

@@ -95,7 +95,7 @@ func (p *streamBufferedPipe) WriteTo(w io.Writer) (n int64, err error) {
 				if !p.rDeadline.IsZero() {
 					p.broadcastAfter(time.Until(p.rDeadline))
 				}
-			} else {
+			} else if enforceTimeout {
 				p.broadcastAfter(p.wtTimeout)
 			}