add Stream::size()

Innmind · Oct 15, 2023 · 902b482 · 902b482
1 parent 8cf0a35
commit 902b482
Show file tree

Hide file tree

Showing 3 changed files with 38 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog
 
+## 2.2.0 - 2023-10-15
+
+### Added
+
+- `Innmind\IO\Readable\Stream::size()`
+
 ## 2.1.0 - 2023-10-15
 
 ### Added

diff --git a/src/Readable/Stream.php b/src/Readable/Stream.php
@@ -6,6 +6,7 @@
 use Innmind\TimeContinuum\ElapsedPeriod;
 use Innmind\Stream\{
     Readable as LowLevelStream,
+    Stream\Size,
     Watch,
 };
 use Innmind\Immutable\{
@@ -140,4 +141,12 @@ public function lines(): Lines
             $this->encoding,
         );
     }
+
+    /**
+     * @return Maybe<Size>
+     */
+    public function size(): Maybe
+    {
+        return $this->stream->size();
+    }
 }
diff --git a/tests/FunctionalTest.php b/tests/FunctionalTest.php
@@ -263,4 +263,27 @@ public function testReadRealFileByLines()
         $this->assertSame("SOFTWARE.\n", $lines[20]->toString());
         $this->assertSame('', $lines[21]->toString());
     }
+
+    public function testSize()
+    {
+        $this
+            ->forAll(Set\Strings::any())
+            ->then(function($content) {
+                $stream = Stream::ofContent($content);
+                $size = IO::of(Select::waitForever(...))
+                    ->readable()
+                    ->wrap($stream)
+                    ->size()
+                    ->match(
+                        static fn($size) => $size->toInt(),
+                        static fn() => null,
+                    );
+
+                $this->assertNotNull($size);
+                $this->assertSame($size, $stream->size()->match(
+                    static fn($size) => $size->toInt(),
+                    static fn() => null,
+                ));
+            });
+    }
 }