Browse Source

clientv3: make IsProgressNotify() false on compact event and closed channel

Fixes #6549
Anthony Romano 9 years ago
parent
commit
bf2581390d
1 changed files with 1 additions and 1 deletions
  1. 1 1
      clientv3/watch.go

+ 1 - 1
clientv3/watch.go

@@ -92,7 +92,7 @@ func (wr *WatchResponse) Err() error {
 
 
 // IsProgressNotify returns true if the WatchResponse is progress notification.
 // IsProgressNotify returns true if the WatchResponse is progress notification.
 func (wr *WatchResponse) IsProgressNotify() bool {
 func (wr *WatchResponse) IsProgressNotify() bool {
-	return len(wr.Events) == 0 && !wr.Canceled && !wr.Created
+	return len(wr.Events) == 0 && !wr.Canceled && !wr.Created && wr.CompactRevision == 0 && wr.Header.Revision != 0
 }
 }
 
 
 // watcher implements the Watcher interface
 // watcher implements the Watcher interface