From 318caeee7e00fd795983961fe3d4fc41d81e3c04 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 ee43b2afeba..c4ec08fc892 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