diff --git a/clientv3/integration/watch_test.go b/clientv3/integration/watch_test.go index 4c9f14757..e36f9a9a8 100644 --- a/clientv3/integration/watch_test.go +++ b/clientv3/integration/watch_test.go @@ -514,6 +514,9 @@ func TestWatchCompactRevision(t *testing.T) { if wresp.Err() != rpctypes.ErrCompacted { t.Fatalf("wresp.Err() expected %v, but got %v", rpctypes.ErrCompacted, wresp.Err()) } + if !wresp.Canceled { + t.Fatalf("wresp.Canceled expected true, got %+v", wresp) + } // ensure the channel is closed if wresp, ok = <-wch; ok {