Draft: Keep JobCollection but use Iterator

src/Infrastructure/ForkingProcessingStrategy.php

@@ -27,7 +27,7 @@ public function process(JobCollection $jobs): void
     {
         $pidList = [];
         $joblist = [];
-        foreach ($jobs->all() as $job) {
+        foreach ($jobs as $job) {
             while (count($pidList) === $this->maxForks) {
                 foreach ($pidList as $pos => $pId) {
                     $code = pcntl_waitpid($pId, $status, WNOHANG);

src/Infrastructure/SingleProcessingStrategy.php

@@ -18,7 +18,7 @@ public function __construct(Executor $executor)
 
     public function process(JobCollection $jobs): void
     {
-        foreach ($jobs->all() as $job) {
+        foreach ($jobs as $job) {
             $this->executor->process($job);
         }
     }

src/Job/JobCollection.php

@@ -4,11 +4,15 @@
 
 namespace simpleQueue\Job;
 
-class JobCollection
+use ArrayIterator;
+
+class JobCollection implements JobIterator
 {
     private array $items = [];
 
-    public function add(Job $job)
+    private int $position = 0;
+
+    public function add(Job $job): void
     {
         $this->items[] = $job;
     }
@@ -20,4 +24,34 @@ public function all(): array
     {
         return $this->items;
     }
+
+    public function getIterator(): ArrayIterator
+    {
+        return new ArrayIterator($this->items);
+    }
+
+    public function current(): mixed
+    {
+        return $this->items[$this->position];
+    }
+
+    public function next(): void
+    {
+        $this->position++;
+    }
+
+    public function key(): int
+    {
+        return $this->position;
+    }
+
+    public function valid(): bool
+    {
+        return isset($this->items[$this->position]);
+    }
+
+    public function rewind(): void
+    {
+        $this->position = 0;
+    }
 }

src/Job/JobIterator.php

@@ -0,0 +1,9 @@
+<?php
+
+declare(strict_types=1);
+
+namespace simpleQueue\Job;
+
+interface JobIterator extends \Iterator
+{
+}