From 3d103e728ce8abf8fd4d0a17f725c1bcdd290803 Mon Sep 17 00:00:00 2001
From: notsure2 <notsure2@protonmail.com>
Date: Mon, 7 Dec 2020 14:22:39 +0200
Subject: [PATCH] When timeout no longer needs to be enforced, no need to
 schedule a broadcast.

---
 internal/multiplex/datagramBufferedPipe.go | 2 +-
 internal/multiplex/streamBufferedPipe.go   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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)
 			}