Fixes

Author: lennardv2

src/ApiClient.php

@@ -54,6 +54,10 @@ protected function handleStream($curl, $streamData) {
             return -1;
         }
 
+        foreach($this->curlHandlers as $handler) {
+            $handler("stream", $streamData);
+        }
+
         foreach(explode("data: ", $streamData) as $bodyParsed) {
             if (!$bodyParsed) continue;
 

src/Client.php

@@ -282,4 +282,17 @@ public function addResultHandler(callable $handler) : self
 
         return $this;
     }
+
+    /**
+     * Adds a handler for curl, first argument holds the type ("request" or "response"), second argument the data.
+     *
+     * @param callable $listener
+     * @return self
+     */
+    public function addCurlHandler(callable $listener) : self
+    {
+        $this->driver->addCurlHandler($listener);
+
+        return $this;
+    }
 }

src/Traits/WithCurlRequests.php

@@ -7,6 +7,18 @@ trait WithCurlRequests
     public bool $shouldAbort = false;
     public bool $isBusy = false;
 
+    public array $curlHandlers = [];
+
+    /**
+     * Adds a new io handler to the client.
+     *
+     * @param callable $handler The handler function to add.
+     */
+    public function addCurlHandler(callable $handler)
+    {
+        $this->curlHandlers[] = $handler;
+    }
+
     /**
      * Sends a JSON request to a specified URL.
      *
@@ -48,9 +60,18 @@ protected function sendJsonRequest(string $method, string $url, array $jsonData,
         $curl = curl_init();
 
         curl_setopt_array($curl, $curlOptions);
+
+        foreach($this->curlHandlers as $handler) {
+            $handler("request", $curlOptions);
+        }
+
         $body = curl_exec($curl);
         curl_close($curl);
 
+        foreach($this->curlHandlers as $handler) {
+            $handler("response", $body);
+        }
+
         try {
             $bodyParsed = json_decode($body, true);
         } catch (\Throwable $th) {