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

Open in your IDE?
  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 $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.     /**
  47.      * {@inheritdoc}
  48.      */
  49.     public function getState(): string
  50.     {
  51.         return $this->promise->getState();
  52.     }
  54.     /**
  55.      * {@inheritdoc}
  56.      *
  57.      * @return Psr7ResponseInterface|mixed
  58.      */
  59.     public function wait($unwrap = true)
  60.     {
  61.         $result = $this->promise->wait($unwrap);
  63.         while ($result instanceof HttplugPromiseInterface || $result instanceof GuzzlePromiseInterface) {
  64.             $result = $result->wait($unwrap);
  65.         }
  67.         return $result;
  68.     }
  70.     private function wrapThenCallback(?callable $callback): ?callable
  71.     {
  72.         if (null === $callback) {
  73.             return null;
  74.         }
  76.         return static function ($value) use ($callback) {
  77.             return Create::promiseFor($callback($value));
  78.         };
  79.     }
  80. }