diff --git a/rafthttp/stream.go b/rafthttp/stream.go index 12c255440..07bc1c204 100644 --- a/rafthttp/stream.go +++ b/rafthttp/stream.go @@ -279,7 +279,7 @@ type streamReader struct { func (r *streamReader) start() { r.stopc = make(chan struct{}) r.done = make(chan struct{}) - if r.errorc != nil { + if r.errorc == nil { r.errorc = r.tr.ErrorC }