From 1a712cf187fdba329a2acb97e57a23058739b7da Mon Sep 17 00:00:00 2001 From: Anthony Romano Date: Wed, 28 Sep 2016 16:47:33 -0700 Subject: [PATCH] clientv3: make IsProgressNotify() false on compact event and closed channel Fixes #6549 --- clientv3/watch.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clientv3/watch.go b/clientv3/watch.go index 2aefb8d10..8534132e8 100644 --- a/clientv3/watch.go +++ b/clientv3/watch.go @@ -92,7 +92,7 @@ func (wr *WatchResponse) Err() error { // IsProgressNotify returns true if the WatchResponse is progress notification. func (wr *WatchResponse) IsProgressNotify() bool { - return len(wr.Events) == 0 && !wr.Canceled + return len(wr.Events) == 0 && !wr.Canceled && !wr.created && wr.CompactRevision == 0 && wr.Header.Revision != 0 } // watcher implements the Watcher interface