From 48dbeb03854335371862f03fb80ff6f766b4ea0b Mon Sep 17 00:00:00 2001 From: Anthony Romano Date: Wed, 19 Jul 2017 13:04:19 -0700 Subject: [PATCH] clientv3: return CompactRevision wresp when set with Canceled --- clientv3/watch.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clientv3/watch.go b/clientv3/watch.go index ee43b2afeba4..c4ec08fc892f 100644 --- a/clientv3/watch.go +++ b/clientv3/watch.go @@ -461,7 +461,7 @@ func (w *watchGrpcStream) run() { if ws := w.nextResume(); ws != nil { wc.Send(ws.initReq.toPB()) } - case pbresp.Canceled: + case pbresp.Canceled && pbresp.CompactRevision == 0: delete(cancelSet, pbresp.WatchId) if ws, ok := w.substreams[pbresp.WatchId]; ok { // signal to stream goroutine to update closingc