diff --git a/events/exchange/exchange_test.go b/events/exchange/exchange_test.go index a79d99cf8..d0acc3aad 100644 --- a/events/exchange/exchange_test.go +++ b/events/exchange/exchange_test.go @@ -52,11 +52,8 @@ func TestExchangeBasic(t *testing.T) { eventq2, errq2 := exchange.Subscribe(ctx2) t.Log("publish") - var wg sync.WaitGroup - wg.Add(1) errChan := make(chan error) go func() { - defer wg.Done() defer close(errChan) for _, event := range testevents { if err := exchange.Publish(ctx, "/test", event); err != nil { @@ -69,7 +66,6 @@ func TestExchangeBasic(t *testing.T) { }() t.Log("waiting") - wg.Wait() if err := <-errChan; err != nil { t.Fatal(err) }