diff --git a/raft/node.go b/raft/node.go index 749db9875..2ec2c3a64 100644 --- a/raft/node.go +++ b/raft/node.go @@ -504,9 +504,9 @@ func (n *node) stepWithWaitOption(ctx context.Context, m pb.Message, wait bool) return ErrStopped } select { - case rsp := <-pm.result: - if rsp != nil { - return rsp + case err := <-pm.result: + if err != nil { + return err } case <-ctx.Done(): return ctx.Err()