func()

in internal/routing/routing.go [136:144]

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

func (b *Batches) handleInput(ctx context.Context) {
	for batches := range b.input {
		for _, r := range b.routes {
			if err := b.push(ctx, r, batches); err != nil {
				b.log.Error(err.Error())
			}
		}
	}
}