From 3737979532b7d54df3f945fa7d9cf724c1c4f4de Mon Sep 17 00:00:00 2001 From: yzm Date: Tue, 16 Jul 2019 12:43:55 -0700 Subject: [PATCH] move wg.Wait() after loop --- integration/v3_watch_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/integration/v3_watch_test.go b/integration/v3_watch_test.go index 940179bb3..9fe2b8024 100644 --- a/integration/v3_watch_test.go +++ b/integration/v3_watch_test.go @@ -491,7 +491,6 @@ func TestV3WatchCurrentPutOverlap(t *testing.T) { } }() } - wg.Wait() // maps watcher to current expected revision progress := make(map[int64]int64) @@ -544,6 +543,8 @@ func TestV3WatchCurrentPutOverlap(t *testing.T) { if rok, nr := waitResponse(wStream, time.Second); !rok { t.Errorf("unexpected pb.WatchResponse is received %+v", nr) } + + wg.Wait() } // TestV3WatchEmptyKey ensures synced watchers see empty key PUTs as PUT events