diff --git a/internal/multiplex/datagramBufferedPipe.go b/internal/multiplex/datagramBufferedPipe.go index ecdec8f..e804c41 100644 --- a/internal/multiplex/datagramBufferedPipe.go +++ b/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) } diff --git a/internal/multiplex/streamBufferedPipe.go b/internal/multiplex/streamBufferedPipe.go index 89ddb55..cb51574 100644 --- a/internal/multiplex/streamBufferedPipe.go +++ b/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) }