fix(merge): calls next reducers complete() on completion

pitchart · May 17, 2020 · bf3a4ff · bf3a4ff
1 parent a899f61
commit bf3a4ff
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/src/Reducer/Merge.php b/src/Reducer/Merge.php
@@ -34,7 +34,7 @@ public function complete($result)
         foreach (($this->collection)() as $item) {
             $result = $this->next->step($result, $item);
         }
-        return $result;
+        return $this->next->complete($result);
     }
 
 }
diff --git a/src/Reducer/Termination/ToCsv.php b/src/Reducer/Termination/ToCsv.php
@@ -5,7 +5,6 @@
 
 
 use Pitchart\Transformer\Termination;
-use function Pitchart\Transformer\Transducer\to_array;
 use function Pitchart\Transformer\transform;
 
 class ToCsv implements Termination