tacone / pipes

src/Filter/FilesTrait.php

Doc Comments +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
      * @param string $path  any file wildcard (ie:/tmp/*.txt). Use the full path!
      * @param int    $flags any GlobIterator or FilesystemIterator flag
      *
-     * @return \Pipes\Pipe
+     * @return FilesTrait
      */
     public function files($path, $flags = \GlobIterator::CURRENT_AS_PATHNAME)
     {

src/Filter/MapTrait.php

Doc Comments +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
      * });
      *
      *
-     * @param callable $callback
+     * @param callable $______callback
      *
      * @return \Pipes\Pipe
      */

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
         if ($reflectionFunction->isGenerator()) {
             $generator = $______callback;
         } else {
-            $generator = function ($iterator) use ($pipe, $______callback) {
+            $generator = function($iterator) use ($pipe, $______callback) {
                 foreach ($iterator as $key => $value) {
                     //                yield $key => $pipe->executeCallback($______callback, true, $value, $key, $iterator);
                     $value = $pipe->executeCallback($______callback, true, $value, $key, $iterator);

docs/daydream.php

Spacing +5 added lines, -5 removed lines

@@ -8,17 +8,17 @@ 
 p($this->getUsers())->limit(1000)->map(function($user) {
     // process the user
     return p::emit($user['id'], $user);
-})->each(function($userData){
+})->each(function($userData) {
     // save the data
 });
 
 // alternative (PHP 5.5) syntax
-p($this)->map(function($value, &$key){
+p($this)->map(function($value, &$key) {
     $key = 4545;
 });
 
 // alternative (PHP 5.5) syntax
-p($this)->map(function($value, $key){
+p($this)->map(function($value, $key) {
     yield $key => $value;
 });
 
@@ -30,7 +30,7 @@ 
  */
 
 p($this->getUsers())->chunk(100)->limit(1000)->each(function($usersChunk) {
-    foreach ( $usersChunk as $user )
+    foreach ($usersChunk as $user)
     {
         print "$user->id \n";
     }
@@ -58,7 +58,7 @@ 
 /**
  * distributing the effort
  */
-p($this->getUsers())->shard(3, function($v, $k, Pipe $p){
+p($this->getUsers())->shard(3, function($v, $k, Pipe $p) {
     echo "shard n. {$p->getShard()}: $k => $v \n";
 });
 

docs/features.php

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
 
 // factory methods
 p()->emit($key = null, $value); //ok
-p()->flags($flag1, $flag2 =null, $flagN = null);
+p()->flags($flag1, $flag2 = null, $flagN = null);
 
 // terminals
 p()->toValues(); // ok. outputs an indexed array.
@@ -59,7 +59,7 @@ 
 // --- advanced stuff
 
 // caching
-p()->keep(3)->each(function(){
+p()->keep(3)->each(function() {
     $previous = p()->kept(-1); // also -2, -3
 });
 

src/Filter/SleepTrait.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
     {
         return $this->chainWith(
             new \CallbackFilterIterator($this->getIterator(),
-                function () use ($seconds) {
+                function() use ($seconds) {
                     usleep($seconds * 1000000);
 
                     return true;

src/Filter/StopIfTrait.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
         $iterator = $this->getIterator();
         $pipe = $this;
 
-        $generator = function () use ($pipe, $iterator, $______callback, $______allArgs) {
+        $generator = function() use ($pipe, $iterator, $______callback, $______allArgs) {
             foreach ($iterator as $key => $value) {
                 if ($pipe->executeCallback($______callback, $______allArgs, $value, $key, $iterator)
                 ) {
@@ -65,7 +65,7 @@ 
         $iterator = $this->getIterator();
         $pipe = $this;
 
-        $generator = function () use ($pipe, $iterator, $______callback, $______allArgs) {
+        $generator = function() use ($pipe, $iterator, $______callback, $______allArgs) {
             foreach ($iterator as $key => $value) {
                 if (!$pipe->executeCallback($______callback, $______allArgs, $value, $key, $iterator)
                 ) {

src/Filter/EachTrait.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
     {
         return $this->chainWith(
             new \CallbackFilterIterator($this->getIterator(),
-                function () use ($______callback, $______allArgs
+                function() use ($______callback, $______allArgs
                 ) {
                     call_user_func_array($______callback, $______allArgs ? func_get_args() : [func_get_arg(0)]);
 

src/PipenessTrait.php

Indentation +1 added lines, -1 removed lines

@@ -116,6 +116,6 @@
         return call_user_func_array(
             $______callback,
             $______allArgs ? [$value, $key, $iterator] : [$value]
-       );
+        );
     }
 }