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

Fixes #6549
This commit is contained in:
Anthony Romano 2016-09-28 16:47:33 -07:00 committed by Gyu-Ho Lee
parent 023f335f67
commit 1a712cf187

View File

@ -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