From 148cc8f713e383f6fc8f1e598ecdd4978cfbcb16 Mon Sep 17 00:00:00 2001 From: Gaurav Singh Date: Mon, 29 Jun 2020 23:28:00 -0400 Subject: [PATCH] [events] Fix deadlock in TestExchangeBasic Signed-off-by: Gaurav Singh --- events/exchange/exchange_test.go | 4 ---- 1 file changed, 4 deletions(-) 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) }