From b60b266eff7c4d040c95608f49f7da71c4cf17af Mon Sep 17 00:00:00 2001 From: bhupeshbhatia <bhatiabh@sheridancollege.ca> Date: Wed, 31 Oct 2018 20:31:56 -0400 Subject: [PATCH] Replace errgroup#wait with errgroup#RoutinesCtx --- main/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/main/main.go b/main/main.go index 7f81554..ea0981c 100644 --- a/main/main.go +++ b/main/main.go @@ -81,8 +81,8 @@ func main() { for { select { - case err := <-eventPoll.Wait(): - err = errors.Wrap(err, "A critical error occurred") + case <-eventPoll.RoutinesCtx().Done(): + err = errors.New("service-context closed") log.Fatalln(err) case eventResp := <-eventPoll.Delete():