initial

Author: vearutop

.gitignore

@@ -0,0 +1,3 @@
+/.idea
+/vendor/
+composer.lock

.travis.yml

@@ -0,0 +1,27 @@
+language: php
+php:
+  - nightly
+  - hhvm
+  - 7.1
+  - 7.0
+  - 5.6
+  - 5.5
+  - 5.4
+
+sudo: false
+
+before_script:
+  - composer install --dev --no-interaction
+
+matrix:
+  allow_failures:
+    - php: hhvm
+    - php: nightly
+  fast_finish: true
+
+script:
+  - ./vendor/bin/phpunit -v --configuration phpunit.xml --coverage-text ./tests/
+
+cache:
+  directories:
+    - $HOME/.composer/cache

LICENSE

@@ -0,0 +1,20 @@
+The MIT License (MIT)
+
+Copyright (c) 2017 Viacheslav Poturaev
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of
+this software and associated documentation files (the "Software"), to deal in
+the Software without restriction, including without limitation the rights to
+use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
+the Software, and to permit persons to whom the Software is furnished to do so,
+subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,17 @@
+# phperf/pipeline
+
+Data processing pipeline 
+
+[![Build Status](https://travis-ci.org/phperf/pipeline.svg?branch=master)](https://travis-ci.org/phperf/pipeline)
+[![Scrutinizer Code Quality](https://scrutinizer-ci.com/g/phperf/pipeline/badges/quality-score.png?b=master)](https://scrutinizer-ci.com/g/phperf/pipeline/?branch=master)
+[![Code Climate](https://codeclimate.com/github/phperf/pipeline/badges/gpa.svg)](https://codeclimate.com/github/phperf/pipeline)
+
+## Installation
+
+```
+composer require phperf/pipeline
+```
+
+## Usage
+
+TBD

composer.json

@@ -0,0 +1,22 @@
+{
+    "name": "phperf/pipeline",
+    "description": "Data processing pipeline",
+    "type": "library",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Viacheslav Poturaev",
+            "email": "[email protected]"
+        }
+    ],
+    "require": {
+    },
+    "autoload": {
+        "psr-4": {
+            "Phperf\\Pipeline\\": "src/"
+        }
+    },
+    "require-dev": {
+        "phpunit/phpunit": "^4.0"
+    }
+}

phpunit.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit
+         colors="true"
+         processIsolation="false"
+         stopOnFailure="false"
+         syntaxCheck="false"
+         convertErrorsToExceptions="true"
+         convertNoticesToExceptions="true"
+         convertWarningsToExceptions="true"
+         testSuiteLoaderClass="PHPUnit_Runner_StandardTestSuiteLoader">
+
+    <testsuites>
+        <testsuite name="Tests">
+            <directory>./tests</directory>
+        </testsuite>
+    </testsuites>
+    <filter>
+        <whitelist processUncoveredFilesFromWhitelist="true">
+            <directory suffix=".php">./src/</directory>
+        </whitelist>
+    </filter>
+
+</phpunit>

src/Page/PageIterator.php

@@ -0,0 +1,101 @@
+<?php
+
+namespace Phperf\Pipeline\Page;
+
+use ArrayIterator;
+use Iterator;
+
+class PageIterator implements Iterator
+{
+    private $iterators;
+    /**
+     * @var Iterator
+     */
+    private $currentIterator;
+
+    function __construct(Iterator $iterators)
+    {
+        $this->iterators = $iterators;
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Return the current element
+     * @link http://php.net/manual/en/iterator.current.php
+     * @return mixed Can return any type.
+     */
+    public function current()
+    {
+        return $this->currentIterator->current();
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Move forward to next element
+     * @link http://php.net/manual/en/iterator.next.php
+     * @return void Any returned value is ignored.
+     */
+    public function next()
+    {
+        $this->currentIterator->next();
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Return the key of the current element
+     * @link http://php.net/manual/en/iterator.key.php
+     * @return mixed scalar on success, or null on failure.
+     */
+    public function key()
+    {
+        //echo 'k';
+        return $this->currentIterator->key();
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Checks if current position is valid
+     * @link http://php.net/manual/en/iterator.valid.php
+     * @return boolean The return value will be casted to boolean and then evaluated.
+     * Returns true on success or false on failure.
+     */
+    public function valid()
+    {
+        $v = $this->currentIterator->valid();
+        if (!$v) {
+            do {
+                $this->iterators->next();
+                if ($this->iterators->valid()) {
+                    $this->currentIterator = $this->iterators->current();
+                    $this->currentIterator->rewind();
+                }
+            } while ($this->iterators->valid() && !$this->currentIterator->valid());
+
+            if (!$this->currentIterator->valid()) {
+                return false;
+            } else {
+                return true;
+            }
+        }
+
+        return $v;
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Rewind the Iterator to the first element
+     * @link http://php.net/manual/en/iterator.rewind.php
+     * @return void Any returned value is ignored.
+     */
+    public function rewind()
+    {
+        $this->iterators->rewind();
+        if (!$this->iterators->valid()) {
+            $this->currentIterator = new ArrayIterator(array());
+        } else {
+            $this->currentIterator = $this->iterators->current();
+        }
+        $this->currentIterator->rewind();
+    }
+
+}

src/Rows/ClosureIterator.php

@@ -0,0 +1,79 @@
+<?php
+
+namespace Phperf\Pipeline\Rows;
+
+use Closure;
+use Iterator;
+
+class ClosureIterator implements Iterator
+{
+    /**
+     * @var callable
+     */
+    private $source;
+    private $currentIterator;
+
+    public function __construct(Closure $source)
+    {
+        $this->source = $source;
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Return the current element
+     * @link http://php.net/manual/en/iterator.current.php
+     * @return mixed Can return any type.
+     */
+    public function current()
+    {
+        return $this->currentIterator;
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Move forward to next element
+     * @link http://php.net/manual/en/iterator.next.php
+     * @return void Any returned value is ignored.
+     */
+    public function next()
+    {
+        $c = $this->source;
+        $this->currentIterator = $c();
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Return the key of the current element
+     * @link http://php.net/manual/en/iterator.key.php
+     * @return mixed scalar on success, or null on failure.
+     */
+    public function key()
+    {
+        return '';
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Checks if current position is valid
+     * @link http://php.net/manual/en/iterator.valid.php
+     * @return boolean The return value will be casted to boolean and then evaluated.
+     * Returns true on success or false on failure.
+     */
+    public function valid()
+    {
+        return (bool)$this->currentIterator;
+    }
+
+    /**
+     * (PHP 5 &gt;= 5.0.0)<br/>
+     * Rewind the Iterator to the first element
+     * @link http://php.net/manual/en/iterator.rewind.php
+     * @return void Any returned value is ignored.
+     */
+    public function rewind()
+    {
+        $c = $this->source;
+        $this->currentIterator = $c();
+    }
+
+}