vendor/symfony/http-client/Response/HttplugPromise.php line 72

  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\HttpClient\Response;
  14. use GuzzleHttp\Promise\Create;
  15. use GuzzleHttp\Promise\PromiseInterface as GuzzlePromiseInterface;
  16. use Http\Promise\Promise as HttplugPromiseInterface;
  17. use Psr\Http\Message\ResponseInterface as Psr7ResponseInterface;
  19. /**
  20.  * @author Tobias Nyholm <tobias.nyholm@gmail.com>
  21.  *
  22.  * @internal
  23.  */
  24. final class HttplugPromise implements HttplugPromiseInterface
  25. {
  26.     private GuzzlePromiseInterface $promise;
  28.     public function __construct(GuzzlePromiseInterface $promise)
  29.     {
  30.         $this->promise = $promise;
  31.     }
  33.     public function then(callable $onFulfilled = null, callable $onRejected = null): self
  34.     {
  35.         return new self($this->promise->then(
  36.             $this->wrapThenCallback($onFulfilled),
  37.             $this->wrapThenCallback($onRejected)
  38.         ));
  39.     }
  41.     public function cancel(): void
  42.     {
  43.         $this->promise->cancel();
  44.     }
  46.     public function getState(): string
  47.     {
  48.         return $this->promise->getState();
  49.     }
  51.     /**
  52.      * @return Psr7ResponseInterface|mixed
  53.      */
  54.     public function wait($unwrap = true): mixed
  55.     {
  56.         $result = $this->promise->wait($unwrap);
  58.         while ($result instanceof HttplugPromiseInterface || $result instanceof GuzzlePromiseInterface) {
  59.             $result = $result->wait($unwrap);
  60.         }
  62.         return $result;
  63.     }
  65.     private function wrapThenCallback(?callable $callback): ?callable
  66.     {
  67.         if (null === $callback) {
  68.             return null;
  69.         }
  71.         return static function ($value) use ($callback) {
  72.             return Create::promiseFor($callback($value));
  73.         };
  74.     }
  75. }