OpenStream should return false if read has error issue#61

xtaci · Jan 20, 2020 · 292d504 · 292d504
1 parent 6da22a1
commit 292d504
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/session.go b/session.go
@@ -139,6 +139,8 @@ func (s *Session) OpenStream() (*Stream, error) {
 	s.streamLock.Lock()
 	defer s.streamLock.Unlock()
 	select {
+	case <-s.chSocketReadError:
+		return nil, s.socketReadError.Load().(error)
 	case <-s.chSocketWriteError:
 		return nil, s.socketWriteError.Load().(error)
 	case <-s.die: