[job-queue] Change typehint, allow not only Closure but other callables too.

makasim · makasim · commit 8013d6982c94 · 2017-12-14T15:36:17.000+02:00
diff --git a/pkg/job-queue/JobRunner.php b/pkg/job-queue/JobRunner.php
@@ -27,11 +27,11 @@ public function __construct(JobProcessor $jobProcessor, Job $rootJob = null)
     /**
      * @param string   $ownerId
      * @param string   $name
-     * @param \Closure $runCallback
+     * @param callable $runCallback
      *
      * @return mixed
      */
-    public function runUnique($ownerId, $name, \Closure $runCallback)
+    public function runUnique($ownerId, $name, callable $runCallback)
     {
         $rootJob = $this->jobProcessor->findOrCreateRootJob($ownerId, $name, true);
         if (!$rootJob) {
@@ -59,11 +59,11 @@ public function runUnique($ownerId, $name, \Closure $runCallback)
 
     /**
      * @param string   $name
-     * @param \Closure $startCallback
+     * @param callable $startCallback
      *
      * @return mixed
      */
-    public function createDelayed($name, \Closure $startCallback)
+    public function createDelayed($name, callable $startCallback)
     {
         $childJob = $this->jobProcessor->findOrCreateChildJob($name, $this->rootJob);
 
@@ -74,11 +74,11 @@ public function createDelayed($name, \Closure $startCallback)
 
     /**
      * @param string   $jobId
-     * @param \Closure $runCallback
+     * @param callable $runCallback
      *
      * @return mixed
      */
-    public function runDelayed($jobId, \Closure $runCallback)
+    public function runDelayed($jobId, callable $runCallback)
     {
         $job = $this->jobProcessor->findJobById($jobId);
         if (!$job) {
