From d2d7690bcce62fc6978666a2559c0d8bd3bf0036 Mon Sep 17 00:00:00 2001 From: xtaci Date: Sun, 9 Feb 2020 18:33:05 +0800 Subject: [PATCH] trigger waitRead to return in SetReadDeadline --- stream.go | 1 + 1 file changed, 1 insertion(+) diff --git a/stream.go b/stream.go index 863d0d1..b21bdef 100644 --- 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 }