From 5d2d780071f6eef25e7f2815035fb90181698fe9 Mon Sep 17 00:00:00 2001
From: Dmitriy Krivopalov <dimarik82@gmail.com>
Date: Sat, 3 Jan 2026 14:33:36 +0300
Subject: [PATCH] core update

---
 composer.json     | 2 +-
 src/Publisher.php | 6 +++++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/composer.json b/composer.json
index 2b4a4c9..e2c994e 100644
--- a/composer.json
+++ b/composer.json
@@ -63,7 +63,7 @@
     ],
     "phpcs": "vendor/bin/phpcs",
     "psalm": "vendor/bin/psalm --show-info --no-diff --no-cache",
-    "phpstan": "vendor/bin/phpstan analyze",
+    "phpstan": "vendor/bin/phpstan analyze -c phpstan.neon",
     "rector": "vendor/bin/rector"
   },
   "minimum-stability": "dev",
diff --git a/src/Publisher.php b/src/Publisher.php
index 84d56a9..0c19ef5 100644
--- a/src/Publisher.php
+++ b/src/Publisher.php
@@ -55,13 +55,17 @@ public function push(SchemaInterface $schema, QueueTask $task, ?QueueContext $co
     }
 
     #[Override]
-    public function pushBatch(SchemaInterface $schema, array $taskBatch, ?QueueContext $context = null): array
+    public function pushBatch(SchemaInterface $schema, iterable $taskBatch, ?QueueContext $context = null): array
     {
         $groupAwait = [];
         foreach ($taskBatch as $task) {
             $groupAwait[] = async($this->push(...), $schema, $task, $context);
         }
 
+        if ($groupAwait === []) {
+            return [];
+        }
+
         /**
          * @var list<non-empty-string>
          */