This commit is contained in:
xtaci
2017-07-01 21:47:59 +08:00
parent 2de5471dfc
commit ebec7ef257
-8
View File
@@ -52,14 +52,6 @@ func (s *Stream) Read(b []byte) (n int, err error) {
}
READ:
select {
case <-s.die:
return 0, errors.New(errBrokenPipe)
case <-deadline:
return n, errTimeout
default:
}
s.bufferLock.Lock()
n, err = s.buffer.Read(b)
s.bufferLock.Unlock()