clientv3: return CompactRevision wresp when set with Canceled

etcd-io · Jul 19, 2017 · 48dbeb0 · 48dbeb0
1 parent 4506ba7
commit 48dbeb0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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