*/
private $promise;
/** @var callable(T):void */
private $resolveCallback;
/** @var callable(\Throwable):void */
private $rejectCallback;
/**
* @param (callable(callable(T):void,callable(\Throwable):void):void)|null $canceller
*/
public function __construct(?callable $canceller = null)
{
$this->promise = new Promise(function ($resolve, $reject) : void {
$this->resolveCallback = $resolve;
$this->rejectCallback = $reject;
}, $canceller);
}
/**
* @return PromiseInterface
*/
public function promise() : PromiseInterface
{
return $this->promise;
}
/**
* @param T $value
*/
public function resolve($value) : void
{
($this->resolveCallback)($value);
}
public function reject(\Throwable $reason) : void
{
($this->rejectCallback)($reason);
}
}