From f045ec2d0b8110c04bc4a77f155453a3d504548c Mon Sep 17 00:00:00 2001 From: Mahmood Ali Date: Wed, 20 Jan 2021 12:41:07 -0500 Subject: [PATCH] e2e: deflake events Handle streamCh channel being closed. --- e2e/events/events.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/e2e/events/events.go b/e2e/events/events.go index 2a545676b..28c0614a1 100644 --- a/e2e/events/events.go +++ b/e2e/events/events.go @@ -218,7 +218,10 @@ func (tc *EventsTest) TestStartIndex(f *framework.F) { select { case <-ctx.Done(): return - case event := <-streamCh: + case event, ok := <-streamCh: + if !ok { + return + } if event.IsHeartbeat() { continue }