@@ -86,6 +86,8 @@ func (s *Stream) Read(b []byte) (n int, err error) {
START:
s.stateLock.Lock()
switch s.state {
+ case streamLocalClose:
+ fallthrough
case streamRemoteClose:
fallthrough
case streamClosed: