feat: check if context is done before grabbing next item
Eric Davis 1 year ago 1f52d550 bbcd73d3
··· 99 99 eventCount int 100 100 ) 101 101 102 102 + queueLoop: 102 103 for { 104 104 + select { 105 105 + case <-ctx.Done(): 106 106 + break queueLoop 107 107 + default: 108 108 + } 109 109 + 103 110 event, ok := queue.Dequeue() 104 111 if !ok { 105 112 time.Sleep(100 * time.Millisecond)