check if deadline timer has been cancelled before signaling

pion · Dec 2, 2023 · d0467a8 · d0467a8
1 parent c08b7f4
commit d0467a8
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