Merge pull request #6 from petrknap/internal-refactoring

Pipelines switched to native shell pipelines

Author: petrknap

src/Filter.php

@@ -112,16 +112,20 @@ private static function checkFinishedProcess(Process $finishedProcess): void
     private static function transformPipeline(array $pipeline): array
     {
         $transformedPipeline = [];
+        $shellCommandLine = null;
         foreach ($pipeline as $filter) {
             if ($filter instanceof self) {
-                $transformedPipeline[] = new Process([
+                $shellCommandLine = ($shellCommandLine === null ? '' : "{$shellCommandLine} | ") . (new Process([
                     $filter->command,
                     ...($filter->options ?? []),
-                ]);
+                ]))->getCommandLine();
             } else {
                 throw new \BadMethodCallException('$pipeline contains unsupported filter');
             }
         }
+        if ($shellCommandLine !== null) {
+            $transformedPipeline[] = Process::fromShellCommandline($shellCommandLine);
+        }
         return $transformedPipeline;
     }
 }