Check deadline timer before signaling

pion · Feb 28, 2024 · 29d0811 · 29d0811
1 parent a5583a6
commit 29d0811
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/stream.go b/stream.go
@@ -175,6 +175,11 @@ func (s *Stream) SetReadDeadline(deadline time.Time) error {
 				t.Stop()
 				return
 			case <-t.C:
+				select {
+				case <-readTimeoutCancel:
+					return
+				default:
+				}
 				s.lock.Lock()
 				if s.readErr == nil {
 					s.readErr = ErrReadDeadlineExceeded