Merge pull request #445 from patchlevel/use-variadic-in-pipeline

use variadic syntax in pipeline to allow bulk save

src/Pipeline/Middleware/ExcludeEventMiddleware.php

@@ -10,7 +10,7 @@ final class ExcludeEventMiddleware implements Middleware
 {
     /** @param list<class-string> $classes */
     public function __construct(
-        private array $classes,
+        private readonly array $classes,
     ) {
     }
 

src/Pipeline/Middleware/IncludeEventMiddleware.php

@@ -10,7 +10,7 @@ final class IncludeEventMiddleware implements Middleware
 {
     /** @param list<class-string> $classes */
     public function __construct(
-        private array $classes,
+        private readonly array $classes,
     ) {
     }
 

src/Pipeline/Middleware/ReplaceEventMiddleware.php

@@ -17,7 +17,7 @@ final class ReplaceEventMiddleware implements Middleware
      * @param callable(T      $event):object $callable
      */
     public function __construct(
-        private string $class,
+        private readonly string $class,
         callable $callable,
     ) {
         $this->callable = $callable;

src/Pipeline/Middleware/UntilEventMiddleware.php

@@ -10,7 +10,7 @@
 final class UntilEventMiddleware implements Middleware
 {
     public function __construct(
-        private DateTimeImmutable $until,
+        private readonly DateTimeImmutable $until,
     ) {
     }
 

src/Pipeline/Pipeline.php

@@ -16,8 +16,8 @@ final class Pipeline
 
     /** @param list<Middleware> $middlewares */
     public function __construct(
-        private Source $source,
-        private Target $target,
+        private readonly Source $source,
+        private readonly Target $target,
         array $middlewares = [],
     ) {
         $this->middlewares = new ChainMiddleware($middlewares);
@@ -27,10 +27,7 @@ public function run(Closure|null $observer = null): void
     {
         foreach ($this->source->load() as $message) {
             $result = ($this->middlewares)($message);
-
-            foreach ($result as $resultMessage) {
-                $this->target->save($resultMessage);
-            }
+            $this->target->save(...$result);
 
             if (!$observer) {
                 continue;

src/Pipeline/Source/StoreSource.php

@@ -13,8 +13,8 @@
 final class StoreSource implements Source
 {
     public function __construct(
-        private Store $store,
-        private int $fromIndex = 0,
+        private readonly Store $store,
+        private readonly int $fromIndex = 0,
     ) {
     }
 

src/Pipeline/Target/InMemoryTarget.php

@@ -11,9 +11,11 @@ final class InMemoryTarget implements Target
     /** @var list<Message> */
     private array $messages = [];
 
-    public function save(Message $message): void
+    public function save(Message ...$messages): void
     {
-        $this->messages[] = $message;
+        foreach ($messages as $message) {
+            $this->messages[] = $message;
+        }
     }
 
     /** @return list<Message> */

src/Pipeline/Target/ProjectorRepositoryTarget.php

@@ -18,9 +18,12 @@ public function __construct(
     ) {
     }
 
-    public function save(Message $message): void
+    public function save(Message ...$messages): void
     {
-        (new ProjectorHelper($this->projectorResolver))
-            ->handleMessage($message, ...$this->projectorRepository->projectors());
+        $helper = new ProjectorHelper($this->projectorResolver);
+
+        foreach ($messages as $message) {
+            $helper->handleMessage($message, ...$this->projectorRepository->projectors());
+        }
     }
 }

src/Pipeline/Target/ProjectorTarget.php

@@ -18,9 +18,12 @@ public function __construct(
     ) {
     }
 
-    public function save(Message $message): void
+    public function save(Message ...$messages): void
     {
-        (new ProjectorHelper($this->projectorResolver))
-            ->handleMessage($message, $this->projector);
+        $helper = new ProjectorHelper($this->projectorResolver);
+
+        foreach ($messages as $message) {
+            $helper->handleMessage($message, $this->projector);
+        }
     }
 }

src/Pipeline/Target/StoreTarget.php

@@ -10,12 +10,12 @@
 final class StoreTarget implements Target
 {
     public function __construct(
-        private Store $store,
+        private readonly Store $store,
     ) {
     }
 
-    public function save(Message $message): void
+    public function save(Message ...$messages): void
     {
-        $this->store->save($message);
+        $this->store->save(...$messages);
     }
 }

src/Pipeline/Target/Target.php

@@ -8,5 +8,5 @@
 
 interface Target
 {
-    public function save(Message $message): void;
+    public function save(Message ...$messages): void;
 }