JobQueueMemory: Actually return values in MappedIterator callback
authorBrad Jorsch <bjorsch@wikimedia.org>
Tue, 12 Sep 2017 15:45:45 +0000 (11:45 -0400)
committerBrad Jorsch <bjorsch@wikimedia.org>
Tue, 12 Sep 2017 15:51:47 +0000 (11:51 -0400)
Change-Id: Ie489d43ba3e9f4a10580716f38ec0f123d9ab5bb

includes/jobqueue/JobQueueMemory.php

index 649e2af..f9e2c3d 100644 (file)
@@ -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 );
                        }
                );
        }