func()

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
}