func()

in logsapi/event.go [59:77]

• 19 lines of code
• 5 McCabe index (conditional complexity)

func (lc *Client) ProcessLogs(
	ctx context.Context,
	requestID string,
	invokedFnArn string,
	dataChan chan []byte,
	isShutdown bool,
) {
	for {
		select {
		case logEvent := <-lc.logsChannel:
			if shouldExit := lc.handleEvent(ctx, logEvent, requestID, invokedFnArn, dataChan, isShutdown); shouldExit {
				return
			}
		case <-ctx.Done():
			lc.logger.Debug("Current invocation over. Interrupting logs processing goroutine")
			return
		}
	}
}