diff --git a/clientv3/integration/watch_test.go b/clientv3/integration/watch_test.go index f553385a9..74e49a17d 100644 --- a/clientv3/integration/watch_test.go +++ b/clientv3/integration/watch_test.go @@ -338,6 +338,9 @@ func putAndWatch(t *testing.T, wctx *watchctx, key, val string) { if !ok { t.Fatalf("unexpected watch close") } + if err := v.Err(); err != nil { + t.Fatalf("unexpected watch response error: %v", err) + } if string(v.Events[0].Kv.Value) != val { t.Fatalf("bad value got %v, wanted %v", v.Events[0].Kv.Value, val) }