← All changes | includes/sdk/google/guzzlehttp/guzzle/src/Handler/MockHandler.php +21 -21 1.2.2 → 1.4.2 View file →

		@@ -1,17 +1,17 @@
1	1	<?php
2	2
3		-namespace Dudlewebs\WPMCS\GuzzleHttp\Handler;
	3	+namespace Dudlewebs\WPMCS\GCP\GuzzleHttp\Handler;
4	4
5		-use Dudlewebs\WPMCS\GuzzleHttp\Exception\RequestException;
6		-use Dudlewebs\WPMCS\GuzzleHttp\HandlerStack;
7		-use Dudlewebs\WPMCS\GuzzleHttp\Promise as P;
8		-use Dudlewebs\WPMCS\GuzzleHttp\Promise\PromiseInterface;
9		-use Dudlewebs\WPMCS\GuzzleHttp\TransferStats;
10		-use Dudlewebs\WPMCS\GuzzleHttp\Utils;
11		-use Dudlewebs\WPMCS\Psr\Http\Message\RequestInterface;
12		-use Dudlewebs\WPMCS\Psr\Http\Message\ResponseInterface;
13		-use Dudlewebs\WPMCS\Psr\Http\Message\StreamInterface;
	5	+use Dudlewebs\WPMCS\GCP\GuzzleHttp\Exception\RequestException;
	6	+use Dudlewebs\WPMCS\GCP\GuzzleHttp\HandlerStack;
	7	+use Dudlewebs\WPMCS\GCP\GuzzleHttp\Promise as P;
	8	+use Dudlewebs\WPMCS\GCP\GuzzleHttp\Promise\PromiseInterface;
	9	+use Dudlewebs\WPMCS\GCP\GuzzleHttp\TransferStats;
	10	+use Dudlewebs\WPMCS\GCP\GuzzleHttp\Utils;
	11	+use Dudlewebs\WPMCS\GCP\Psr\Http\Message\RequestInterface;
	12	+use Dudlewebs\WPMCS\GCP\Psr\Http\Message\ResponseInterface;
	13	+use Dudlewebs\WPMCS\GCP\Psr\Http\Message\StreamInterface;
14	14	/**
15	15	* Handler that returns responses or throw exceptions from a queue.
16	16	*
17	17	* @final
		@@ -45,9 +45,9 @@
45	45	* @param array|null $queue Array of responses, callables, or exceptions.
46	46	* @param callable|null $onFulfilled Callback to invoke when the return value is fulfilled.
47	47	* @param callable|null $onRejected Callback to invoke when the return value is rejected.
48	48	*/
49		- public static function createWithMiddleware(?array $queue = null, ?callable $onFulfilled = null, ?callable $onRejected = null): HandlerStack
	49	+ public static function createWithMiddleware(?array $queue = null, ?callable $onFulfilled = null, ?callable $onRejected = null) : HandlerStack
50	50	{
51	51	return HandlerStack::create(new self($queue, $onFulfilled, $onRejected));
52	52	}
53	53	/**
		@@ -64,12 +64,12 @@
64	64	$this->onFulfilled = $onFulfilled;
65	65	$this->onRejected = $onRejected;
66	66	if ($queue) {
67	67	// array_values included for BC
68		- $this->append(...array_values($queue));
	68	+ $this->append(...\array_values($queue));
69	69	}
70	70	}
71		- public function __invoke(RequestInterface $request, array $options): PromiseInterface
	71	+ public function __invoke(RequestInterface $request, array $options) : PromiseInterface
72	72	{
73	73	if (!$this->queue) {
74	74	throw new \OutOfBoundsException('Mock queue is empty');
75	75	}
		@@ -93,9 +93,9 @@
93	93	if (\is_callable($response)) {
94	94	$response = $response($request, $options);
95	95	}
96	96	$response = $response instanceof \Throwable ? P\Create::rejectionFor($response) : P\Create::promiseFor($response);
97		- return $response->then(function (?ResponseInterface $value) use ($request, $options) {
	97	+ return $response->then(function (?ResponseInterface $value) use($request, $options) {
98	98	$this->invokeStats($request, $options, $value);
99	99	if ($this->onFulfilled) {
100	100	($this->onFulfilled)($value);
101	101	}
		@@ -110,9 +110,9 @@
110	110	$sink->write($contents);
111	111	}
112	112	}
113	113	return $value;
114		- }, function ($reason) use ($request, $options) {
	114	+ }, function ($reason) use($request, $options) {
115	115	$this->invokeStats($request, $options, null, $reason);
116	116	if ($this->onRejected) {
117	117	($this->onRejected)($reason);
118	118	}
		@@ -124,9 +124,9 @@
124	124	* to the queue.
125	125	*
126	126	* @param mixed ...$values
127	127	*/
128		- public function append(...$values): void
	128	+ public function append(...$values) : void
129	129	{
130	130	foreach ($values as $value) {
131	131	if ($value instanceof ResponseInterface || $value instanceof \Throwable || $value instanceof PromiseInterface || \is_callable($value)) {
132	132	$this->queue[] = $value;
		@@ -137,9 +137,9 @@
137	137	}
138	138	/**
139	139	* Get the last received request.
140	140	*/
141		- public function getLastRequest(): ?RequestInterface
	141	+ public function getLastRequest() : ?RequestInterface
142	142	{
143	143	return $this->lastRequest;
144	144	}
145	145	/**
		@@ -144,9 +144,9 @@
144	144	}
145	145	/**
146	146	* Get the last received request options.
147	147	*/
148		- public function getLastOptions(): array
	148	+ public function getLastOptions() : array
149	149	{
150	150	return $this->lastOptions;
151	151	}
152	152	/**
		@@ -151,13 +151,13 @@
151	151	}
152	152	/**
153	153	* Returns the number of remaining items in the queue.
154	154	*/
155		- public function count(): int
	155	+ public function count() : int
156	156	{
157	157	return \count($this->queue);
158	158	}
159		- public function reset(): void
	159	+ public function reset() : void
160	160	{
161	161	$this->queue = [];
162	162	}
163	163	/**
		@@ -162,9 +162,9 @@
162	162	}
163	163	/**
164	164	* @param mixed $reason Promise or reason.
165	165	*/
166		- private function invokeStats(RequestInterface $request, array $options, ?ResponseInterface $response = null, $reason = null): void
	166	+ private function invokeStats(RequestInterface $request, array $options, ?ResponseInterface $response = null, $reason = null) : void
167	167	{
168	168	if (isset($options['on_stats'])) {
169	169	$transferTime = $options['transfer_time'] ?? 0;
170	170	$stats = new TransferStats($request, $response, $transferTime, $reason);