in pkg/scheduler/scheduler.go [52:59]
func (s *Scheduler) WithErrorListeners(listeners ...ErrorListener) *Scheduler { for i := range s.sources { for j := range listeners { s.sources[i].WithErrorListeners(listeners[j]) } } return s }