diff --git a/src/Command/RunSubscriptionsCommand.php b/src/Command/RunSubscriptionsCommand.php index 3872a3c..5261255 100644 --- a/src/Command/RunSubscriptionsCommand.php +++ b/src/Command/RunSubscriptionsCommand.php @@ -99,6 +99,13 @@ protected function execute(InputInterface $input, OutputInterface $output) while ($this->runningProcesses() >= $limit) { $this->output(); } + + // run infinitely? + if (false === $subscriptions->valid()) { + $subscriptions = $this->subscriptions->all($filter); + $subscriptions = new \IteratorIterator($subscriptions); + $subscriptions->rewind(); + } } while ($this->runningProcesses()) {