in pkg/events/events.go [178:191]
func (ev *events) reconcileEventsDataChannelHandler(pollerCh <-chan int) {
for {
select {
case bufferPtr, ok := <-pollerCh:
if !ok {
return
}
ev.readRingBuffer(ev.RingBuffers[bufferPtr])
case <-ev.eventsStopChannel:
return
}
}
}