processor_listener_test.go

const concurrencyLevel …

func BenchmarkListener(b *testing.B) { … }