| @@ 161-166 (lines=6) @@ | ||
| 158 | $result = $query->execute(); |
|
| 159 | ||
| 160 | $jobs = []; |
|
| 161 | while ($row = $result->fetch()) { |
|
| 162 | $job = $this->buildJob($row); |
|
| 163 | if ($job) { |
|
| 164 | $jobs[] = $job; |
|
| 165 | } |
|
| 166 | } |
|
| 167 | $result->closeCursor(); |
|
| 168 | ||
| 169 | return $jobs; |
|
| @@ 335-342 (lines=8) @@ | ||
| 332 | ->from('jobs'); |
|
| 333 | $result = $query->execute(); |
|
| 334 | ||
| 335 | while ($row = $result->fetch()) { |
|
| 336 | $job = $this->buildJob($row); |
|
| 337 | if ($job) { |
|
| 338 | if ($callback($job) === false) { |
|
| 339 | break; |
|
| 340 | } |
|
| 341 | } |
|
| 342 | } |
|
| 343 | $result->closeCursor(); |
|
| 344 | } |
|
| 345 | } |
|