From 2fa8ae764fdd7fe4ce3dd93bb855517a5e00f796 Mon Sep 17 00:00:00 2001
From: "Buster \"Silver Eagle\" Neece" <buster@busterneece.com>
Date: Thu, 16 Jul 2020 18:12:24 -0500
Subject: [PATCH] Update return pattern for process() so it allows arrays.

---
 src/Workers/AbstractQueueWorker.php | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/Workers/AbstractQueueWorker.php b/src/Workers/AbstractQueueWorker.php
index 043d643..9a5b946 100644
--- a/src/Workers/AbstractQueueWorker.php
+++ b/src/Workers/AbstractQueueWorker.php
@@ -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);
 }