exposing last value

Author: vearutop

src/Vector/Custom.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace Phperf\Pipeline\Vector;
+
+
+class Custom implements VectorProcessor
+{
+    /** @var callable */
+    private $callable;
+
+    public function __construct(callable $callable)
+    {
+        $this->callable = $callable;
+    }
+
+    public function value($value)
+    {
+        $c = $this->callable;
+        return $c($value);
+    }
+
+
+}

src/Vector/DropAnomaly.php

@@ -6,10 +6,13 @@ class DropAnomaly implements VectorProcessor
 {
     private $deviation;
     private $prevValue;
+    /** @var VectorProcessor */
+    private $processor;
 
     public function __construct($deviation = 0.5)
     {
         $this->deviation = $deviation;
+        $this->processor = new MovingAverage(6);
     }
 
     public function value($value)
@@ -20,10 +23,11 @@ public function value($value)
             if ($delta > $allowedDelta) {
                 return null;
             } else {
+                $this->prevValue = $this->processor->value($value);
                 return $value;
             }
         } else {
-            $this->prevValue = $value;
+            $this->prevValue = $this->processor->value($value);
             return $value;
         }
     }

src/Vector/Pipeline.php

@@ -13,9 +13,17 @@ public function addProcessor(VectorProcessor $processor)
         return $this;
     }
 
+    private $lastValue;
+
+    public function getLastValue()
+    {
+        return $this->lastValue;
+    }
+
     public function value($value)
     {
         if ($value === null) {
+            $this->lastValue = null;
             return null;
         }
         foreach ($this->processors as $processor) {
@@ -24,6 +32,7 @@ public function value($value)
                 break;
             }
         }
+        $this->lastValue = $value;
         return $value;
     }
 }