Я изучаю ампф. Я хочу преобразовать вызов синхронизации в асинхронный вызов, используя цикл событий в ampphp. В моем примере кода используется file_get_contents
в качестве примера блокировки вызова.
Используя вызов синхронизации, это выглядит так:
$uris = [
"https://google.com/",
"https://github.com/",
"https://stackoverflow.com/",
];
$results = [];
foreach ($uris as $uri) {
var_dump("fetching $uri..");
$results[$uri] = file_get_contents($uri);
var_dump("done fetching $uri.");
}
foreach ($results as $uri => $result) {
var_dump("uri : $uri");
var_dump("result : " . strlen($result));
}
И вывод:
string(30) "fetching https://google.com/.."
string(34) "done fetching https://google.com/."
string(30) "fetching https://github.com/.."
string(34) "done fetching https://github.com/."
string(37) "fetching https://stackoverflow.com/.."
string(41) "done fetching https://stackoverflow.com/."
string(25) "uri : https://google.com/"
string(14) "result : 48092"
string(25) "uri : https://github.com/"
string(14) "result : 65749"
string(32) "uri : https://stackoverflow.com/"
string(15) "result : 260394"
Я знаю, что есть artax, который делает вызов асинхронно. Но я хочу научиться правильно превращать блокирующий код в асинхронный параллельный код (не параллельный). Я уже успешно реализую его параллельно, используя amp.
Я считаю, что правильный вывод, если я успешно реализую его в асинхронном режиме в усилителе, будет примерно таким:
string(30) "fetching https://google.com/.."
string(30) "fetching https://github.com/.."
string(37) "fetching https://stackoverflow.com/.."
string(34) "done fetching https://google.com/."
string(34) "done fetching https://github.com/."
string(41) "done fetching https://stackoverflow.com/."
string(25) "uri : https://google.com/"
string(14) "result : 48124"
string(25) "uri : https://github.com/"
string(14) "result : 65749"
string(32) "uri : https://stackoverflow.com/"
string(15) "result : 260107"
Я пробовал с этим кодом:
<?php
require __DIR__ . '/vendor/autoload.php';
use Amp\Loop;
use function Amp\call;
Loop::run(function () {
$uris = [
"https://google.com/",
"https://github.com/",
"https://stackoverflow.com/",
];
foreach ($uris as $uri) {
$promises[$uri] = call(function () use ($uri) {
var_dump("fetching $uri..");
$result = file_get_contents($uri);
var_dump("done fetching $uri.");
yield $result;
});
}
$responses = yield $promises;
foreach ($responses as $uri => $result) {
var_dump("uri : $uri");
var_dump("result : " . strlen($result));
}
});
Вместо того, чтобы дать мне ожидаемый результат, он дает мне эту ошибку:
string(30) "fetching https://google.com/.."
string(34) "done fetching https://google.com/."
string(30) "fetching https://github.com/.."
string(34) "done fetching https://github.com/."
string(37) "fetching https://stackoverflow.com/.."
string(41) "done fetching https://stackoverflow.com/."
PHP Fatal error: Uncaught Amp\InvalidYieldError: Unexpected yield; Expected an instance of Amp\Promise or React\Promise\PromiseInterface or an array of such instances; string yielded at key 0 on line 20
Результат также кажется синхронизированным, а не асинхронным.
Как мне правильно это сделать?