func()

in batching/batching.go [263:272]

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

func (b *Batcher) emit(ctx context.Context) {
	batches := b.current
	for sourceType, batch := range batches {
		metrics.Emitted(ctx, sourceType, len(batch.Data), time.Since(batch.age))
	}

	n := getBatches()
	b.current = n
	b.out <- batches
}