ARCH-414 Fix psalm issues

ecentria · Nov 15, 2024 · 56fe951 · 56fe951
1 parent abcaaa7
commit 56fe951
Showing 1 changed file with 3 additions and 9 deletions.
diff --git a/src/Symfony/Component/Messenger/Worker.php b/src/Symfony/Component/Messenger/Worker.php
@@ -115,19 +115,13 @@ public function run(array $options = []): void
             $envelopeHandledStart = $this->clock->now();
             foreach ($this->receivers as $transportName => $receiver) {
                 if ($blockingMode) {
-                    $callback = function (Envelope $envelope) use ($transportName, &$envelopeHandled) {
+                    $callback = function (Envelope $envelope) use ($transportName, &$envelopeHandled): ?bool {
                         $envelopeHandled = true;
                         $this->handleMessage($envelope, $transportName);
 
-                        if ($this->eventDispatcher !== null) {
-                            $this->eventDispatcher->dispatch(new WorkerRunningEvent($this, false));
-                        }
-
-                        if ($this->shouldStop) {
-                            return false;
-                        }
+                        $this->eventDispatcher?->dispatch(new WorkerRunningEvent($this, false));
 
-                        return true;
+                        return !$this->shouldStop;
                     };
 
                     if ($queueNames) {