func()

in batching/batching.go [210:228]

• 16 lines of code
• 4 McCabe index (conditional complexity)

func (b *Batcher) run(ctx context.Context) {
	defer close(b.out)

	timer := time.NewTimer(b.timespan)
	ticker := time.NewTicker(b.timespan)
	defer ticker.Stop()

	for {
		timer.Reset(b.timespan)

		exit, err := b.handleInput(context.WithoutCancel(ctx), timer.C)
		if err != nil {
			b.log.Error(err.Error())
		}
		if exit {
			return
		}
	}
}