danog/amp
1
0
Fork 0
mirror of https://github.com/danog/amp.git synced 2024-11-27 04:24:42 +01:00
Code Issues Projects Releases Wiki Activity

Remove driver argument

Browse Source
This commit is contained in:
Aaron Piotrowski 2016-05-26 00:09:50 -05:00
parent ccec7acc94
commit dd70850682
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lib/functions.php
View File

@ -4,7 +4,6 @@ namespace Amp;
use Interop\Async\Awaitable;
use Interop\Async\Loop;
use Interop\Async\LoopDriver;
/**
* Returns a new function that when invoked runs the Generator returned by $worker as a coroutine.
@ -48,14 +47,20 @@ function rethrow(Awaitable $awaitable) {
*
* @throws \Throwable|\Exception Awaitable failure reason.
*/
function wait(Awaitable $awaitable, LoopDriver $driver = null) {
Loop::execute(function () use (&$value, &$exception, $awaitable) {
$awaitable->when(function ($e, $v) use (&$value, &$exception) {
function wait(Awaitable $awaitable) {
$resolved = false;
Loop::execute(function () use (&$resolved, &$value, &$exception, $awaitable) {
$awaitable->when(function ($e, $v) use (&$resolved, &$value, &$exception) {
Loop::stop();
$resolved = true;
$exception = $e;
$value = $v;
});
}, $driver ?: Loop::get());
});
if (!$resolved) {
throw new \LogicException("Loop emptied without resolving awaitable");
}
if ($exception) {
throw $exception;