update api

src/Message/Pipe.php

@@ -18,17 +18,12 @@ final class Pipe implements IteratorAggregate
 {
     private Translator $translator;
 
-    /**
-     * @param iterable<Message>           $messages
-     * @param list<Translator>|Translator $translators
-     */
+    /** @param iterable<Message> $messages */
     public function __construct(
         private readonly iterable $messages,
-        array|Translator $translators = [],
+        Translator ...$translators,
     ) {
-        $this->translator = $translators instanceof Translator
-            ? $translators
-            : new ChainTranslator($translators);
+        $this->translator = new ChainTranslator($translators);
     }
 
     /** @return Traversable<Message> */
@@ -56,7 +51,9 @@ public function toArray(): array
     private function createGenerator(iterable $messages, Translator $translator): Generator
     {
         foreach ($messages as $message) {
-            yield from $translator($message);
+            foreach ($translator($message) as $translatedMessage) {
+                yield $translatedMessage;
+            }
         }
     }
 }

tests/Integration/Subscription/Subscriber/MigrateAggregateToStreamStoreSubscriber.php

@@ -56,7 +56,7 @@ public function beginBatch(): void
 
     public function commitBatch(): void
     {
-        $pipeline = new Pipe($this->messages, $this->middlewares);
+        $pipeline = new Pipe($this->messages, ...$this->middlewares);
         $this->messages = [];
 
         $this->targetStore->save(...$pipeline);

tests/Unit/Message/PipeTest.php

@@ -85,10 +85,8 @@ public function testWithMiddlewares(): void
 
         $stream = new Pipe(
             $messages,
-            [
-                new ExcludeEventTranslator([ProfileCreated::class]),
-                new RecalculatePlayheadTranslator(),
-            ],
+            new ExcludeEventTranslator([ProfileCreated::class]),
+            new RecalculatePlayheadTranslator(),
         );
 
         $resultMessages = iterator_to_array($stream);

tests/Unit/Message/Translator/ChainTranslatorTest.php

@@ -18,6 +18,20 @@ final class ChainTranslatorTest extends TestCase
 {
     use ProphecyTrait;
 
+    public function testEmptyChain(): void
+    {
+        $message = new Message(
+            new ProfileCreated(
+                ProfileId::fromString('1'),
+                Email::fromString('[email protected]'),
+            ),
+        );
+
+        $translator = new ChainTranslator([]);
+
+        self::assertSame([$message], $translator($message));
+    }
+
     public function testChain(): void
     {
         $message = new Message(
@@ -38,6 +52,6 @@ public function testChain(): void
             $child2->reveal(),
         ]);
 
-        $translator($message);
+        self::assertSame([$message], $translator($message));
     }
 }