diff --git a/clientv3/lease.go b/clientv3/lease.go index 129043eb5..2be2abc12 100644 --- a/clientv3/lease.go +++ b/clientv3/lease.go @@ -218,7 +218,7 @@ func (l *lessor) recvKeepAliveLoop() { resp, err := stream.Recv() if err != nil { - err := l.switchRemoteAndStream(err) + err = l.switchRemoteAndStream(err) if err != nil { l.Close() return @@ -278,14 +278,14 @@ func (l *lessor) sendKeepAliveLoop() { var err error for _, id := range tosend { r := &pb.LeaseKeepAliveRequest{ID: int64(id)} - err := stream.Send(r) + err = stream.Send(r) if err != nil { break } } if err != nil { - err := l.switchRemoteAndStream(err) + err = l.switchRemoteAndStream(err) if err != nil { l.Close() return