bug fix for https://github.com/xtaci/smux/issues/82

2024-04-21 10:51:48 +00:00 · 2020-11-25 22:53:43 +08:00
parent f7188026ba
commit fa45f32081
1 changed files with 6 additions and 0 deletions
@@ -272,6 +272,12 @@ func (s *Stream) waitRead() error {
 	case <-s.chReadEvent:
 		return nil
 	case <-s.chFinEvent:
+		// BUG(xtaci): Fix for https://github.com/xtaci/smux/issues/82
+		s.bufferLock.Lock()
+		defer s.bufferLock.Unlock()
+		if len(s.buffers) > 0 {
+			return nil
+		}
 		return io.EOF
 	case <-s.sess.chSocketReadError:
 		return s.sess.socketReadError.Load().(error)