<?php namespace GuzzleHttp\Promise; /** * A promise that has been fulfilled. * * Thenning off of this promise will invoke the onFulfilled callback * immediately and ignore other callbacks. */ class FulfilledPromise implements PromiseInterface { private $value; public function __construct($value) { if (is_object($value) && method_exists($value, 'then')) { throw new \InvalidArgumentException( 'You cannot create a FulfilledPromise with a promise.' ); } $this->value = $value; } public function then( callable $onFulfilled = null, callable $onRejected = null ) { // Return itself if there is no onFulfilled function. if (!$onFulfilled) { return $this; } $queue = Utils::queue(); $p = new Promise([$queue, 'run']); $value = $this->value; $queue->add(static function () use ($p, $value, $onFulfilled) { if (Is::pending($p)) { try { $p->resolve($onFulfilled($value)); } catch (\Throwable $e) { $p->reject($e); } catch (\Exception $e) { $p->reject($e); } } }); return $p; } public function otherwise(callable $onRejected) { return $this->then(null, $onRejected); } public function wait($unwrap = true, $defaultDelivery = null) { return $unwrap ? $this->value : null; } public function getState() { return self::FULFILLED; } public function resolve($value) { if ($value !== $this->value) { throw new \LogicException("Cannot resolve a fulfilled promise"); } } public function reject($reason) { throw new \LogicException("Cannot reject a fulfilled promise"); } public function cancel() { // pass } }
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
AggregateException.php | File | 380 B | 0644 |
|
CancellationException.php | File | 183 B | 0644 |
|
Coroutine.php | File | 4.24 KB | 0644 |
|
Create.php | File | 2.06 KB | 0644 |
|
Each.php | File | 2.82 KB | 0644 |
|
EachPromise.php | File | 7.6 KB | 0644 |
|
FulfilledPromise.php | File | 1.94 KB | 0644 |
|
Is.php | File | 999 B | 0644 |
|
Promise.php | File | 8.73 KB | 0644 |
|
PromiseInterface.php | File | 2.79 KB | 0644 |
|
PromisorInterface.php | File | 244 B | 0644 |
|
RejectedPromise.php | File | 2.23 KB | 0644 |
|
RejectionException.php | File | 1.19 KB | 0644 |
|
TaskQueue.php | File | 1.89 KB | 0644 |
|
TaskQueueInterface.php | File | 433 B | 0644 |
|
Utils.php | File | 8.5 KB | 0644 |
|
functions.php | File | 9.89 KB | 0644 |
|
functions_include.php | File | 167 B | 0644 |
|