1
0
mirror of https://github.com/danog/amp.git synced 2024-12-13 09:57:25 +01:00
amp/lib/Internal/WhenQueue.php
Aaron Piotrowski a309a243c2 Fix formatting
2016-05-21 12:07:08 -05:00

58 lines
1.5 KiB
PHP

<?php
namespace Amp\Awaitable\Internal;
use Interop\Async\Loop;
class WhenQueue {
/**
* @var callable[]
*/
private $queue = [];
/**
* @param callable|null $callback Initial callback to add to queue.
*/
public function __construct(callable $callback = null) {
if (null !== $callback) {
$this->push($callback);
}
}
/**
* Calls each callback in the queue, passing the provided values to the function.
*
* @param \Throwable|\Exception|null $exception
* @param mixed $value
*/
public function __invoke($exception = null, $value = null) {
foreach ($this->queue as $callback) {
try {
$callback($exception, $value);
} catch (\Throwable $exception) {
Loop::defer(static function ($watcher, $exception) {
throw $exception;
}, $exception);
} catch (\Exception $exception) {
Loop::defer(static function ($watcher, $exception) {
throw $exception;
}, $exception);
}
}
}
/**
* Unrolls instances of self to avoid blowing up the call stack on resolution.
*
* @param callable $callback
*/
public function push(callable $callback) {
if ($callback instanceof self) {
$this->queue = \array_merge($this->queue, $callback->queue);
return;
}
$this->queue[] = $callback;
}
}