diff --git a/packages/http/src/AsyncHttpClient.php b/packages/http/src/AsyncHttpClient.php index a6a54da51..90271f422 100644 --- a/packages/http/src/AsyncHttpClient.php +++ b/packages/http/src/AsyncHttpClient.php @@ -116,7 +116,7 @@ public function reset(): static * @return Promise * @throws RangeException */ - public function senRequest(RequestInterface $request): ResponseInterface + public function sendRequest(RequestInterface $request): ResponseInterface { /** @var CurlTransport $transport */ $transport = $this->getTransport(); @@ -136,6 +136,20 @@ public function senRequest(RequestInterface $request): ResponseInterface return $promise; } + /** + * Send a request to remote. + * + * @param RequestInterface $request The PSR request object. + * + * @return Promise + * + * @deprecated Use sendRequest() instead. + */ + public function senRequest(RequestInterface $request): ResponseInterface + { + return $this->sendRequest($request); + } + /** * resolve * diff --git a/packages/http/test/AsyncHttpClientTest.php b/packages/http/test/AsyncHttpClientTest.php index b8d57be52..5b9176888 100644 --- a/packages/http/test/AsyncHttpClientTest.php +++ b/packages/http/test/AsyncHttpClientTest.php @@ -93,7 +93,17 @@ public function setTransportRejectsStreamTransport(): void } #[Test] - public function senRequestQueuesTaskAndReturnsPromise(): void + public function sendRequestQueuesTaskAndReturnsPromise(): void + { + $promise = $this->instance->sendRequest($this->createRequest('/json?a=1')); + + self::assertInstanceOf(PromiseResponse::class, $promise); + self::assertCount(1, $this->instance->getHandles()); + self::assertCount(1, $this->instance->getTasks()); + } + + #[Test] + public function senRequestForwardsToSendRequest(): void { $promise = $this->instance->senRequest($this->createRequest('/json?a=1')); @@ -105,8 +115,8 @@ public function senRequestQueuesTaskAndReturnsPromise(): void #[Test] public function resolveReturnsResponsesForAllQueuedRequests(): void { - $this->instance->senRequest($this->createRequest('/json?a=1')); - $this->instance->senRequest($this->createRequest('/json?a=2')); + $this->instance->sendRequest($this->createRequest('/json?a=1')); + $this->instance->sendRequest($this->createRequest('/json?a=2')); $responses = $this->instance->resolve(); @@ -122,7 +132,7 @@ public function resolveResolvesPromisesWithResponses(): void { $received = []; - $promise = $this->instance->senRequest($this->createRequest('/json?a=3')); + $promise = $this->instance->sendRequest($this->createRequest('/json?a=3')); $promise->then( function (Response $res) use (&$received) { $received[] = (string) $res->getBody(); @@ -139,7 +149,7 @@ function (Response $res) use (&$received) { #[Test] public function resolveInvokesCallbackWithResponsesErrorsAndClient(): void { - $this->instance->senRequest($this->createRequest('/json?a=1')); + $this->instance->sendRequest($this->createRequest('/json?a=1')); $args = null; @@ -159,7 +169,7 @@ public function resolveRejectsPromiseAndCollectsErrorOnConnectionFailure(): void { $failure = null; - $promise = $this->instance->senRequest( + $promise = $this->instance->sendRequest( $this->createUrlRequest('http://127.0.0.1:1/unreachable'), ); $promise->fail( @@ -187,7 +197,7 @@ function (array $responses, array $errs) use (&$errors) { #[Test] public function resolveResetsQueueAfterCompletion(): void { - $this->instance->senRequest($this->createRequest('/json?a=1')); + $this->instance->sendRequest($this->createRequest('/json?a=1')); $this->instance->resolve(); self::assertSame([], $this->instance->getHandles()); @@ -197,7 +207,7 @@ public function resolveResetsQueueAfterCompletion(): void #[Test] public function resetClearsTasksAndMainHandle(): void { - $this->instance->senRequest($this->createRequest('/json?a=1')); + $this->instance->sendRequest($this->createRequest('/json?a=1')); $mh = $this->instance->getMainHandle(); self::assertSame($this->instance, $this->instance->reset());