1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- <?php
- namespace Symfony\Component\HttpClient\Response;
- use GuzzleHttp\Promise\Create;
- use GuzzleHttp\Promise\PromiseInterface as GuzzlePromiseInterface;
- use Http\Promise\Promise as HttplugPromiseInterface;
- use Psr\Http\Message\ResponseInterface as Psr7ResponseInterface;
- final class HttplugPromise implements HttplugPromiseInterface
- {
- private $promise;
- public function __construct(GuzzlePromiseInterface $promise)
- {
- $this->promise = $promise;
- }
- public function then(callable $onFulfilled = null, callable $onRejected = null): self
- {
- return new self($this->promise->then(
- $this->wrapThenCallback($onFulfilled),
- $this->wrapThenCallback($onRejected)
- ));
- }
- public function cancel(): void
- {
- $this->promise->cancel();
- }
-
- public function getState(): string
- {
- return $this->promise->getState();
- }
-
- public function wait($unwrap = true)
- {
- $result = $this->promise->wait($unwrap);
- while ($result instanceof HttplugPromiseInterface || $result instanceof GuzzlePromiseInterface) {
- $result = $result->wait($unwrap);
- }
- return $result;
- }
- private function wrapThenCallback(?callable $callback): ?callable
- {
- if (null === $callback) {
- return null;
- }
- return static function ($value) use ($callback) {
- return Create::promiseFor($callback($value));
- };
- }
- }
|