trigger waitRead to return in SetReadDeadline

xtaci · Feb 9, 2020 · d2d7690 · d2d7690
1 parent 0d0f7cd
commit d2d7690
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/stream.go b/stream.go
@@ -447,6 +447,7 @@ func (s *Stream) GetDieCh() <-chan struct{} {
 // A zero time value disables the deadline.
 func (s *Stream) SetReadDeadline(t time.Time) error {
 	s.readDeadline.Store(t)
+	s.notifyReadEvent()
 	return nil
 }