tacone / pipes

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/MapTrait.php

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);

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)]);