watch the streams before reading from them

Innmind · Nov 5, 2023 · 85e65bf · 85e65bf
1 parent 10a81de
commit 85e65bf
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog
 
+## [Unreleased]
+
+### Added
+
+- Watch the streams before reading from them (allows for an easy integration in `Fiber`s)
+
 ## 7.2.0- 2023-11-01
 
 ### Added

diff --git a/src/File/Content/AtPath.php b/src/File/Content/AtPath.php
@@ -76,6 +76,7 @@ public function lines(): Sequence
             $io = $this->io->wrap($stream);
 
             yield $io
+                ->watch()
                 ->lines()
                 ->lazy()
                 ->sequence();
@@ -122,6 +123,7 @@ public function chunks(): Sequence
             $io = $this->io->wrap($stream);
 
             yield $io
+                ->watch()
                 ->chunks(8192)
                 ->lazy()
                 ->sequence();

diff --git a/src/File/Content/IO.php b/src/File/Content/IO.php
@@ -57,6 +57,7 @@ public function lines(): Sequence
         /** @psalm-suppress ImpureMethodCall */
         return $this
             ->io
+            ->watch()
             ->lines()
             ->lazy()
             ->rewindable()
@@ -88,6 +89,7 @@ public function chunks(): Sequence
         /** @psalm-suppress ImpureMethodCall */
         return $this
             ->io
+            ->watch()
             ->chunks(8192)
             ->lazy()
             ->rewindable()

diff --git a/src/File/Content/OneShot.php b/src/File/Content/OneShot.php
@@ -61,6 +61,7 @@ public function lines(): Sequence
 
             yield $this
                 ->io
+                ->watch()
                 ->lines()
                 ->lazy()
                 ->sequence();
@@ -95,6 +96,7 @@ public function chunks(): Sequence
 
             yield $this
                 ->io
+                ->watch()
                 ->chunks(8192)
                 ->lazy()
                 ->sequence();