From 60b11b1ba95b6b11015ff701304925336251c808 Mon Sep 17 00:00:00 2001 From: Joachim Bauch Date: Tue, 8 Jun 2021 09:44:53 +0200 Subject: [PATCH] Don't start test until receiving goroutine is ready. --- natsclient_test.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/natsclient_test.go b/natsclient_test.go index 67f377b..ee45b61 100644 --- a/natsclient_test.go +++ b/natsclient_test.go @@ -65,8 +65,10 @@ func testNatsClient_Subscribe(t *testing.T, client NatsClient) { received := int32(0) max := int32(20) + ready := make(chan bool) quit := make(chan bool) go func() { + ready <- true for { select { case <-dest: @@ -84,6 +86,7 @@ func testNatsClient_Subscribe(t *testing.T, client NatsClient) { } } }() + <-ready for i := int32(0); i < max; i++ { if err := client.Publish("foo", []byte("hello")); err != nil { t.Error(err)