vendor/ezimuel/ringphp/src/Future/CompletedFutureValue.php line 65

Open in your IDE?
  1. <?php
  2. namespace GuzzleHttp\Ring\Future;
  4. use React\Promise\FulfilledPromise;
  5. use React\Promise\RejectedPromise;
  6. use React\Promise\PromiseInterface;
  8. /**
  9.  * Represents a future value that has been resolved or rejected.
  10.  */
  11. class CompletedFutureValue implements FutureInterface
  12. {
  13.     protected $result;
  14.     protected $error;
  16.     private $cachedPromise;
  18.     /**
  19.      * @param mixed      $result Resolved result
  20.      * @param \Exception $e      Error. Pass a GuzzleHttp\Ring\Exception\CancelledFutureAccessException
  21.      *                           to mark the future as cancelled.
  22.      */
  23.     public function __construct($result, \Exception $e = null)
  24.     {
  25.         $this->result = $result;
  26.         $this->error = $e;
  27.     }
  29.     /**
  30.      * @return mixed
  31.      */
  32.     public function wait()
  33.     {
  34.         if ($this->error) {
  35.             throw $this->error;
  36.         }
  38.         return $this->result;
  39.     }
  41.     public function cancel() {}
  43.     /**
  44.      * @return PromiseInterface
  45.      */
  46.     public function promise()
  47.     {
  48.         if (!$this->cachedPromise) {
  49.             $this->cachedPromise = $this->error
  50.                 ? new RejectedPromise($this->error)
  51.                 : new FulfilledPromise($this->result);
  52.         }
  54.         return $this->cachedPromise;
  55.     }
  57.     /**
  58.      * @return PromiseInterface
  59.      */
  60.     public function then(
  61.         callable $onFulfilled = null,
  62.         callable $onRejected = null,
  63.         callable $onProgress = null
  64.     ) {
  65.         return $this->promise()->then($onFulfilled, $onRejected, $onProgress);
  66.     }
  67. }