update

Author: inhere

src/Components/Pipeline.php

@@ -0,0 +1,75 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: inhere
+ * Date: 2017/10/16
+ * Time: 下午11:59
+ * @link https://github.com/ztsu/pipe/blob/master/src/Pipeline.php
+ */
+
+namespace Inhere\Library\Components;
+
+use Inhere\Library\Interfaces\PipelineInterface;
+
+/**
+ * Class Pipeline
+ * @package Inhere\Library\Components
+ */
+class Pipeline implements PipelineInterface
+{
+    /** @var \SplObjectStorage  */
+    private $stages;
+
+    public function __construct()
+    {
+        $this->stages = new \SplObjectStorage;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function add(callable $stage)
+    {
+        if ($stage instanceof $this) {
+            $stage->add(function($payload) {
+                return $this->invokeStage($payload);
+            });
+        }
+
+        $this->stages->attach($stage);
+
+        return $this;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function run($payload)
+    {
+        $this->stages->rewind();
+
+        return $this->invokeStage($payload);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function __invoke($payload)
+    {
+        return $this->run($payload);
+    }
+
+    private function invokeStage($payload)
+    {
+        $stage = $this->stages->current();
+        $this->stages->next();
+
+        if (is_callable($stage)) {
+            return $stage($payload, function($payload) {
+                return $this->invokeStage($payload);
+            });
+        }
+
+        return $payload;
+    }
+}

src/Interfaces/MiddlewareInterface.php

@@ -0,0 +1,40 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: inhere
+ * Date: 2017/10/17
+ * Time: 上午12:01
+ */
+
+namespace Inhere\Library\Interfaces;
+
+/**
+ * Interface PipelineInterface
+ * @package Inhere\Library\Interfaces
+ */
+interface PipelineInterface
+{
+    /**
+     * Adds stage to the pipelene
+     *
+     * @param callable $stage
+     * @return $this
+     */
+    public function add(callable $stage);
+
+    /**
+     * Runs pipeline with initial value
+     *
+     * @param mixed $payload
+     * @return mixed
+     */
+    public function run($payload);
+
+    /**
+     * Makes pipeline callable. Does same as {@see run()}
+     *
+     * @param mixed $payload
+     * @return mixed
+     */
+    public function __invoke($payload);
+}