Merge "JobQueueGroup: Improve failed-to-insert error"

[lhc/web/wiklou.git] / includes / jobqueue / JobQueueMemory.php

diff --git a/includes/jobqueue/JobQueueMemory.php b/includes/jobqueue/JobQueueMemory.php
index 649e2af..f9e2c3d 100644 (file)
--- a/includes/jobqueue/JobQueueMemory.php
+++ b/includes/jobqueue/JobQueueMemory.php
@@ -177,7 +177,7 @@ class JobQueueMemory extends JobQueue {
                return new MappedIterator(
                        $unclaimed,
                        function ( $value ) {
-                               $this->jobFromSpecInternal( $value );
+                               return $this->jobFromSpecInternal( $value );
                        }
                );
        }
@@ -196,7 +196,7 @@ class JobQueueMemory extends JobQueue {
                return new MappedIterator(
                        $claimed,
                        function ( $value ) {
-                               $this->jobFromSpecInternal( $value );
+                               return $this->jobFromSpecInternal( $value );
                        }
                );
        }