Skip to content

Commit c3be30a

Browse files
authored
Fix timeout value passed to taskWaitMulti (#380)
1 parent 6ca4392 commit c3be30a

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/Swoole/SwooleTaskDispatcher.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public function resolve(array $tasks, int $waitMilliseconds = 3000): array
3434
return [$key => $task instanceof Closure
3535
? new SerializableClosure($task)
3636
: $task, ];
37-
})->all(), $waitMilliseconds);
37+
})->all(), $waitMilliseconds / 1000);
3838

3939
if ($results === false) {
4040
throw TaskTimeoutException::after($waitMilliseconds);

tests/SwooleTaskDispatcherTest.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ public function test_resolving_tasks_may_timeout()
4040

4141
$this->instance(Server::class, Mockery::mock(Server::class, function ($mock) {
4242
$mock->shouldReceive('taskWaitMulti')
43+
->with(\Mockery::any(), 2)
4344
->once()
4445
->andReturn(false);
4546
}));

0 commit comments

Comments
 (0)