diff --git a/tests/integration/clientv3/watch_test.go b/tests/integration/clientv3/watch_test.go index 7a992ecf9..e4474c23c 100644 --- a/tests/integration/clientv3/watch_test.go +++ b/tests/integration/clientv3/watch_test.go @@ -340,6 +340,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) }