Compare commits
1 commit
12f64696df
...
593dd77d84
Author | SHA1 | Date | |
---|---|---|---|
593dd77d84 |
1 changed files with 3 additions and 1 deletions
|
@ -109,7 +109,9 @@ func (s *serverStreamReaderCloser) ReadMessage(msg message.Message) error {
|
|||
|
||||
err = s.rw.ReadMessage(msg)
|
||||
if !errors.Is(err, io.EOF) {
|
||||
s.rw.cancel()
|
||||
if err != nil {
|
||||
s.rw.cancel()
|
||||
}
|
||||
return err
|
||||
}
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue