youzan / php-co-koa Goto Github PK

RT

race 与timeout 里
// helper function
function await($task, ...$args)
{
if ($task instanceof \Generator) {
return $task;
}

if (is_callable($task)) {
    $gen = function() use($task, $args) { yield $task(...$args); };
} else {
    $gen = function() use($task) { yield $task; };
}
return $gen();

}

在这个函数里这么调，await 函数永远也不会得到第二个参数。
有一种情况是，当 执行await时，$task为 Syscall对象时，就执行$gen = function() use($task, $args) { yield $task(...$args); }; 此时 $args为空啊，报错。
PHP Fatal error: Uncaught ArgumentCountError: Too few arguments to function Syscall::__invoke(), 0 passed in /home/eric/phpcode/co/Gen.php on line 502 and exactly 1 expected in /home/eric/phpcode/co/Gen.php:158
Stack trace:
#0 /home/eric/phpcode/co/Gen.php(502): Syscall->__invoke()
#1 [internal function]: {closure}()
#2 /home/eric/phpcode/co/Gen.php(24): Generator->current()
#3 /home/eric/phpcode/co/Gen.php(114): Gen->send(NULL)
#4 /home/eric/phpcode/co/Gen.php(98): AsyncTask->next()
#5 /home/eric/phpcode/co/Gen.php(474): AsyncTask->begin(Object(Closure))
#6 /home/eric/phpcode/co/Gen.php(129): Any->begin(Array)
#7 /home/eric/phpcode/co/Gen.php(98): AsyncTask->next()
#8 /home/eric/phpcode/co/Gen.php(320): AsyncTask->begin(Object(Closure))
#9 /home/eric/phpcode/co/Gen.php(578): spawn(Object(Closure))
function race(array $tasks)
{
$tasks = array_map(NAMESPACE . "\await", $tasks);

return new Syscall(function(AsyncTask $parent) use($tasks) {
    if (empty($tasks)) {
        return null;
    } else {
        return new Any($tasks, $parent);
    }
});

}

race与timeout 这篇里
// helper function
function await($task, ...$args)
{
if ($task instanceof \Generator) {
return $task;
}

if (is_callable($task)) {
    $gen = function() use($task, $args) { yield $task(...$args); };
} else {
    $gen = function() use($task) { yield $task; };
}
return $gen();

}

await 函数作为array_map的回调函数能接受第二个参数吗？