Merge pull request #3 from michael-rubel/feature/pipeline-helper

Add `pipeline` helper

Author: michael-rubel

composer.json

@@ -32,7 +32,10 @@
     "autoload": {
         "psr-4": {
             "MichaelRubel\\EnhancedPipeline\\": "src"
-        }
+        },
+        "files": [
+            "src/Helpers/helpers.php"
+        ]
     },
     "autoload-dev": {
         "psr-4": {

src/Helpers/helpers.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+use MichaelRubel\EnhancedPipeline\Pipeline;
+
+if (! function_exists('pipeline')) {
+    /**
+     * @param  mixed  $passable
+     * @param  array|mixed  $pipes
+     *
+     * @return Pipeline
+     */
+    function pipeline($passable, $pipes): Pipeline
+    {
+        return app(Pipeline::class)
+            ->send($passable)
+            ->through($pipes);
+    }
+}

tests/PipelineTest.php

@@ -145,6 +145,15 @@ public function rollsTheDatabaseTransactionBackOnFailureWhenOnFailureMethodUsed(
         $database->shouldHaveReceived('beginTransaction')->once();
         $database->shouldHaveReceived('rollBack')->once();
     }
+
+    /** @test */
+    public function testPipelineHelper()
+    {
+        $test = pipeline('test', fn ($data, $next) => $next($data))
+            ->thenReturn();
+
+        $this->assertSame('test', $test);
+    }
 }
 
 class PipelineWithException