Added asynchronous option to PendingRequest

Author: Sammyjo20

src/Contracts/PendingRequest.php

@@ -232,4 +232,19 @@ public function sendAsync(): PromiseInterface;
      * @return mixed
      */
     public function createDtoFromResponse(Response $response): mixed;
+
+    /**
+     * Set if the request is going to be sent asynchronously
+     *
+     * @param bool $asynchronous
+     * @return $this
+     */
+    public function setAsynchronous(bool $asynchronous): static;
+
+    /**
+     * Check if the request is asynchronous
+     *
+     * @return bool
+     */
+    public function isAsynchronous(): bool;
 }

src/Http/Dispatcher.php

@@ -16,9 +16,8 @@ class Dispatcher implements DispatcherContract
      * Constructor
      *
      * @param PendingRequest $pendingRequest
-     * @param bool $asynchronous
      */
-    public function __construct(protected PendingRequest $pendingRequest, protected bool $asynchronous = false)
+    public function __construct(protected PendingRequest $pendingRequest)
     {
         //
     }
@@ -37,7 +36,7 @@ public function execute(): Response|PromiseInterface
         // to create the SimulatedResponse and return that. Otherwise, we
         // will send a real request to the sender.
 
-        $response = $this->getSender()->sendRequest($pendingRequest, $this->asynchronous);
+        $response = $this->getSender()->sendRequest($pendingRequest, $pendingRequest->isAsynchronous());
 
         // Next we will need to run the response pipeline. If the response
         // is a Response we can run it directly, but if it is

src/Http/PendingRequest.php

@@ -87,6 +87,13 @@ class PendingRequest implements PendingRequestContract
      */
     protected ?SimulatedResponsePayload $simulatedResponsePayload = null;
 
+    /**
+     * Determine if the pending request is asynchronous
+     *
+     * @var bool
+     */
+    protected bool $asynchronous = false;
+
     /**
      * Build up the request payload.
      *
@@ -436,6 +443,8 @@ protected function resolveResponseClass(): string
      */
     public function send(): ResponseContract
     {
+        $this->setAsynchronous(false);
+
         return (new Dispatcher($this))->execute();
     }
 
@@ -446,7 +455,9 @@ public function send(): ResponseContract
      */
     public function sendAsync(): PromiseInterface
     {
-        return (new Dispatcher($this, true))->execute();
+        $this->setAsynchronous(true);
+
+        return (new Dispatcher($this))->execute();
     }
 
     /**
@@ -459,4 +470,27 @@ public function createDtoFromResponse(ResponseContract $response): mixed
     {
         return $this->request->createDtoFromResponse($response) ?? $this->connector->createDtoFromResponse($response);
     }
+
+    /**
+     * Set if the request is going to be sent asynchronously
+     *
+     * @param bool $asynchronous
+     * @return PendingRequestContract
+     */
+    public function setAsynchronous(bool $asynchronous): static
+    {
+        $this->asynchronous = $asynchronous;
+
+        return $this;
+    }
+
+    /**
+     * Check if the request is asynchronous
+     *
+     * @return bool
+     */
+    public function isAsynchronous(): bool
+    {
+        return $this->asynchronous;
+    }
 }

src/Http/Pool.php

@@ -141,8 +141,10 @@ public function getRequests(): Generator
      * Send the pool and create a Promise
      *
      * @return \GuzzleHttp\Promise\PromiseInterface
+     * @throws \ReflectionException
      * @throws \Saloon\Exceptions\InvalidPoolItemException
-     * @throws \Saloon\Exceptions\SaloonException
+     * @throws \Saloon\Exceptions\InvalidResponseClassException
+     * @throws \Saloon\Exceptions\PendingRequestException
      */
     public function send(): PromiseInterface
     {

tests/Feature/AsyncRequestTest.php

@@ -25,6 +25,7 @@
 
     $data = $response->json();
 
+    expect($response->getPendingRequest()->isAsynchronous())->toBeTrue();
     expect($response->isMocked())->toBeFalse();
     expect($response->status())->toEqual(200);
 

tests/Feature/RequestTest.php

@@ -16,6 +16,7 @@
 
     $data = $response->json();
 
+    expect($response->getPendingRequest()->isAsynchronous())->toBeFalse();
     expect($response)->toBeInstanceOf(Response::class);
     expect($response->isMocked())->toBeFalse();
     expect($response->status())->toEqual(200);