feat(client): add streaming

Author: stainless-app[bot]

src/Core/Adapters/GeneratorStream.php

@@ -0,0 +1,19 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Scrapegraphai\Core\Contracts;
+
+/**
+ * @template TInner
+ *
+ * @extends \IteratorAggregate<int,TInner>
+ */
+interface CloseableStream extends \IteratorAggregate
+{
+    /**
+     * Manually force the stream to close early.
+     * Iterating through will automatically close as well.
+     */
+    public function close(): void;
+}

src/Core/Contracts/CloseableStream.php

@@ -265,13 +265,13 @@ public static function decodeLines(\Iterator $stream): \Iterator
     /**
      * @param \Iterator<string> $lines
      *
-     * @return \Iterator<
+     * @return \Generator<
      *   array{
      *     event?: null|string, data?: null|string, id?: null|string, retry?: null|int
      *   },
      * >
      */
-    public static function decodeSSE(\Iterator $lines): \Iterator
+    public static function decodeSSE(\Iterator $lines): \Generator
     {
         $blank = ['event' => null, 'data' => null, 'id' => null, 'retry' => null];
         $acc = [];