diff --git a/contrib/extension/subscription/client_test.go b/contrib/extension/subscription/client_test.go index b63d6e2fbf5ca5a9380927adbfb69cd622dedbc8..73a412d06243df690233bf9db16ba1728af07499 100644 --- a/contrib/extension/subscription/client_test.go +++ b/contrib/extension/subscription/client_test.go @@ -172,11 +172,9 @@ func TestCloseClient(t *testing.T) { return } - go func() { - if err := cl.Close(); err != nil { - t.Error(err) - } - }() + time.AfterFunc(10*time.Millisecond, func() { + _ = cl.Close() + }) for { select {