Benzine/Core
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update return pattern for process() so it allows arrays.

Browse source
This commit is contained in:
Buster "Silver Eagle" Neece 2020-07-16 18:12:24 -05:00
parent c4854f78d9
commit 2fa8ae764f
No known key found for this signature in database
GPG key ID: 6D9E12FF03411F4E
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/Workers/AbstractQueueWorker.php
View file

@ -131,7 +131,7 @@ abstract class AbstractQueueWorker extends AbstractWorker
foreach ($items as $item) {
$processResults = $this->process($item);
if (is_array($processResults)) {
foreach ($processResults as $processResult) {
$this->resultItems[] = $processResult;
@ -186,5 +186,10 @@ abstract class AbstractQueueWorker extends AbstractWorker
return sprintf('%s:failures', $this->inputQueue);
}
abstract protected function process(WorkerWorkItem $item): ?WorkerWorkItem;
/**
* @param WorkerWorkItem $item
*
* @return WorkerWorkItem|WorkerWorkItem[]|null
*/
abstract protected function process(WorkerWorkItem $item);
}