chore: rename Utils.php to NdJson.php and update method references

Author: awu

src/Client.php

@@ -5,11 +5,9 @@
 namespace Thenativeweb\Eventsourcingdb;
 
 use DateTimeImmutable;
-use Exception;
 use GuzzleHttp\Client as HttpClient;
-use GuzzleHttp\Exception\GuzzleException;
 use RuntimeException;
-use Thenativeweb\Eventsourcingdb\Stream\Utils;
+use Thenativeweb\Eventsourcingdb\Stream\NdJson;
 
 final readonly class Client
 {
@@ -25,9 +23,6 @@ public function __construct(string $url, string $apiToken)
         ]);
     }
 
-    /**
-     * @throws GuzzleException
-     */
     public function ping(): void
     {
         $response = $this->httpClient->get('/api/v1/ping');
@@ -48,9 +43,6 @@ public function ping(): void
         }
     }
 
-    /**
-     * @throws GuzzleException
-     */
     public function verifyApiToken(): void
     {
         $response = $this->httpClient->post(
@@ -78,10 +70,6 @@ public function verifyApiToken(): void
         }
     }
 
-    /**
-     * @return iterable<CloudEvent>
-     * @throws Exception|GuzzleException
-     */
     public function writeEvents(array $events, array $preconditions = []): iterable
     {
         $requestBody = [
@@ -143,10 +131,6 @@ public function writeEvents(array $events, array $preconditions = []): iterable
         }
     }
 
-    /**
-     * @return iterable<CloudEvent>
-     * @throws Exception|GuzzleException
-     */
     public function readEvents(string $subject, ReadEventsOptions $readEventsOptions): iterable
     {
         $requestBody = [
@@ -173,7 +157,7 @@ public function readEvents(string $subject, ReadEventsOptions $readEventsOptions
             ));
         }
 
-        foreach (Utils::readNdJson($response->getBody()) as $eventLine) {
+        foreach (NdJson::readStream($response->getBody()) as $eventLine) {
             switch ($eventLine->type) {
                 case 'event':
                     $cloudEvent = new CloudEvent(

src/Stream/Utils.php src/Stream/NdJson.phpsrc/Stream/Utils.php renamed to src/Stream/NdJson.php

@@ -7,7 +7,7 @@
 use Psr\Http\Message\StreamInterface;
 use RuntimeException;
 
-final readonly class Utils
+final readonly class NdJson
 {
     public static function readLine(StreamInterface $stream): string
     {
@@ -27,10 +27,7 @@ public static function readLine(StreamInterface $stream): string
         return $buffer;
     }
 
-    /**
-     * @return iterable<ReadEventLine>
-     */
-    public static function readNdJson(StreamInterface $stream): iterable
+    public static function readStream(StreamInterface $stream): iterable
     {
         while (!$stream->eof()) {
             $line = self::readLine($stream);