src/EventRunner.php
public function handle(OutputInterface $output, array $schedules = []): void
    {
        $this->schedules = $schedules;
        $this->output = $output;

        foreach ($this->schedules as $schedule) {
            $this->consoleLogger
                ->debug("Invoke Schedule's ping before");

            $this->pingBefore($schedule);

            // Running the before-callbacks of the current schedule
            $this->invoke($schedule->beforeCallbacks());

            $events = $schedule->events();
            foreach ($events as $event) {
                $this->start($event);
            }
        }

        // Watch events until they are finished
        $this->manageStartedEvents();
    }
public function handle(OutputInterface $output, array $schedules = []): void
    {
        $this->schedules = $schedules;
        $this->output = $output;

        foreach ($this->schedules as $schedule) {
            $this->consoleLogger
                ->debug("Invoke Schedule's ping before");

            $this->pingBefore($schedule);

            // Running the before-callbacks of the current schedule
            $this->invoke($schedule->beforeCallbacks());

            $events = $schedule->events();
            foreach ($events as $event) {
                $this->start($event);
            }
        }

        // Watch events until they are finished
        $this->manageStartedEvents();
    }
public function handle ( OutputInterface $ output , array $ schedules = [ ] ) : void { $ this -> schedules = $ schedules ; $ this -> output = $ output ; foreach ( $ this -> schedules as $ schedule ) { $ this -> consoleLogger -> debug ( "Invoke Schedule's ping before" ) ; $ this -> pingBefore ( $ schedule ) ; // Running the before-callbacks of the current schedule $ this -> invoke ( $ schedule -> beforeCallbacks ( ) ) ; $ events = $ schedule -> events ( ) ; foreach ( $ events as $ event ) { $ this -> start ( $ event ) ; } } // Watch events until they are finished $ this -> manageStartedEvents ( ) ; }
Handle an array of Schedule objects.
Handle an array of Schedule objects .