diff --git a/tests/integration/clientv3/experimental/recipes/v3_queue_test.go b/tests/integration/clientv3/experimental/recipes/v3_queue_test.go index 22d01545e..20a635929 100644 --- a/tests/integration/clientv3/experimental/recipes/v3_queue_test.go +++ b/tests/integration/clientv3/experimental/recipes/v3_queue_test.go @@ -37,6 +37,9 @@ func TestQueueOneReaderOneWriter(t *testing.T) { defer clus.Terminate(t) done := make(chan struct{}) + defer func() { + <-done + }() go func() { defer func() { done <- struct{}{} @@ -61,7 +64,6 @@ func TestQueueOneReaderOneWriter(t *testing.T) { t.Fatalf("expected dequeue value %v, got %v", s, i) } } - <-done } func TestQueueManyReaderOneWriter(t *testing.T) {