clientv3: correct the nextRev on receving progress notification response

Signed-off-by: Benjamin Wang <wachao@vmware.com>
This commit is contained in:
Benjamin Wang
2023-02-10 09:41:52 +08:00
parent 346f1d325a
commit e896cc7201
2 changed files with 98 additions and 1 deletions

View File

@@ -848,7 +848,7 @@ func (w *watchGrpcStream) serveSubstream(ws *watcherStream, resumec chan struct{
}
} else {
// current progress of watch; <= store revision
nextRev = wr.Header.Revision
nextRev = wr.Header.Revision + 1
}
if len(wr.Events) > 0 {