func NewMultiProcessor()

in v2/processor.go [127:139]

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

func NewMultiProcessor(receiversEx []*ReceiverEx, handler HandlerFunc, options *ProcessorOptions) *Processor {
	opts := applyProcessorOptions(options)
	var receivers = make(map[string]*ReceiverEx)
	for _, receiver := range receiversEx {
		receivers[receiver.name] = receiver
	}
	return &Processor{
		receivers:         receivers,
		handle:            handler,
		options:           *opts,
		concurrencyTokens: make(chan struct{}, opts.MaxConcurrency),
	}
}