client: fix potentially dropped streaming errors
This commit is contained in:
parent
4b44b9039b
commit
9a7e6be2b6
|
@ -276,6 +276,15 @@ OUTER:
|
|||
break OUTER
|
||||
case frame, ok := <-frames:
|
||||
if !ok {
|
||||
// frame may have been closed when an error
|
||||
// occurred. Check once more for an error.
|
||||
select {
|
||||
case streamErr = <-errCh:
|
||||
// There was a pending error!
|
||||
default:
|
||||
// No error, continue on
|
||||
}
|
||||
|
||||
break OUTER
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue