[Collection] Stream emitsPairs method.

Author: whsv26

src/Fp/Streams/Stream.php

@@ -143,6 +143,22 @@ public static function emits(iterable $source): self
         return new self($source);
     }
 
+    /**
+     * @inheritDoc
+     * @template TKI
+     * @template TVI
+     * @param iterable<TKI, TVI> $source
+     * @return self<array{TKI, TVI}>
+     */
+    public static function emitsPairs(iterable $source): self
+    {
+        return self::emits(asGenerator(function () use ($source) {
+            foreach ($source as $key => $val) {
+                yield [$key, $val];
+            }
+        }));
+    }
+
     /**
      * @inheritDoc
      * @param 0|positive-int $seconds

src/Fp/Streams/StreamEmitter.php

@@ -40,6 +40,16 @@ public static function emit(mixed $elem): Stream;
      */
     public static function emits(iterable $source): Stream;
 
+    /**
+     * Emits key/value pairs from iterable source
+     *
+     * @template TKI
+     * @template TVI
+     * @param iterable<TKI, TVI> $source
+     * @return self<array{TKI, TVI}>
+     */
+    public static function emitsPairs(iterable $source): self;
+
     /**
      * Repeat this stream an infinite number of times.
      *

tests/Runtime/Classes/Stream/StreamEmitterTest.php

@@ -31,4 +31,9 @@ public function testRange(): void
         $this->assertEquals([0, 1], Stream::range(0, 2)->toArray());
         $this->assertEquals([0, 2, 4], Stream::range(0, 5, 2)->toArray());
     }
+
+    public function testEmitsPairs(): void
+    {
+        $this->assertEquals([['a', 1]], Stream::emitsPairs(['a' => 1])->toArray());
+    }
 }

tests/Static/Classes/Stream/StreamStaticTest.php

@@ -12,7 +12,7 @@ final class StreamStaticTest
      * @psalm-param int $input
      * @psalm-return Stream<int>
      */
-    public function testEmit(mixed $input): mixed
+    public function testEmit(mixed $input): Stream
     {
         return Stream::emit($input);
     }
@@ -21,8 +21,17 @@ public function testEmit(mixed $input): mixed
      * @psalm-param array{1, 2, 'a'} $input
      * @psalm-return Stream<1|2|'a'>
      */
-    public function testEmits(mixed $input): mixed
+    public function testEmits(mixed $input): Stream
     {
         return Stream::emits($input);
     }
+
+    /**
+     * @psalm-param array<int, string> $input
+     * @psalm-return Stream<array{int, string}>
+     */
+    public function testEmitsPairs(mixed $input): Stream
+    {
+        return Stream::emitsPairs($input);
+    }
 }