check deadline timer before signaling

pion · Feb 26, 2024 · 7961bab · 7961bab
1 parent ee5f2e7
commit 7961bab
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