Skip to content

Commit 26c39bc

Browse files
authored
Merge pull request #292 from php-enqueue/job-queue-change-typehint
[job-queue] Change typehint, allow not only Closure but other callabl…
2 parents 027a805 + 8013d69 commit 26c39bc

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

Diff for: pkg/job-queue/JobRunner.php

+6-6
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,11 @@ public function __construct(JobProcessor $jobProcessor, Job $rootJob = null)
2727
/**
2828
* @param string $ownerId
2929
* @param string $name
30-
* @param \Closure $runCallback
30+
* @param callable $runCallback
3131
*
3232
* @return mixed
3333
*/
34-
public function runUnique($ownerId, $name, \Closure $runCallback)
34+
public function runUnique($ownerId, $name, callable $runCallback)
3535
{
3636
$rootJob = $this->jobProcessor->findOrCreateRootJob($ownerId, $name, true);
3737
if (!$rootJob) {
@@ -59,11 +59,11 @@ public function runUnique($ownerId, $name, \Closure $runCallback)
5959

6060
/**
6161
* @param string $name
62-
* @param \Closure $startCallback
62+
* @param callable $startCallback
6363
*
6464
* @return mixed
6565
*/
66-
public function createDelayed($name, \Closure $startCallback)
66+
public function createDelayed($name, callable $startCallback)
6767
{
6868
$childJob = $this->jobProcessor->findOrCreateChildJob($name, $this->rootJob);
6969

@@ -74,11 +74,11 @@ public function createDelayed($name, \Closure $startCallback)
7474

7575
/**
7676
* @param string $jobId
77-
* @param \Closure $runCallback
77+
* @param callable $runCallback
7878
*
7979
* @return mixed
8080
*/
81-
public function runDelayed($jobId, \Closure $runCallback)
81+
public function runDelayed($jobId, callable $runCallback)
8282
{
8383
$job = $this->jobProcessor->findJobById($jobId);
8484
if (!$job) {

0 commit comments

Comments
 (0)