diff --git a/tests/collector_test.go b/tests/collector_test.go
index daaf0b07..7df7d7b8 100644
--- a/tests/collector_test.go
+++ b/tests/collector_test.go
@@ -109,9 +109,12 @@ func (c *eventCollector) getEventCh(ofType events.Event) <-chan events.Event {
 }
 
 func (c *eventCollector) close() {
+	c.lock.Lock()
+	defer c.lock.Unlock()
 	c.wg.Wait()
 
 	for _, eventCh := range c.events {
 		eventCh.CloseAndDiscardQueued()
 	}
+	c.events = nil
 }