func logAndEmit()

in main.go [35:38]

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

func logAndEmit(ctx context.Context, element string, emit func(string)) {
	beamLog.Infoln(ctx, element)
	emit(element)
}