gielfeldt / iterators

src/SortIterator.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
         $this->direction = $direction;
         $this->flags = $flags;
         $this->callback = \Closure::fromCallable($callback);
-        $this->realCallback = $direction == self::SORT_ASC ? $this->callback : function ($cmpA, $cmpB) {
+        $this->realCallback = $direction == self::SORT_ASC ? $this->callback : function($cmpA, $cmpB) {
             return ($this->callback)($cmpB, $cmpA);
         };
         parent::__construct($this->getSortedIterator($iterator));

src/AtomicTempFileObject.php

Spacing +3 added lines, -3 removed lines

@@ -140,7 +140,7 @@ 
     {
         $callback = \Closure::fromCallable($callback);
         $input->rewind();
-        iterator_apply($input, function (\Iterator $iterator) use ($callback) {
+        iterator_apply($input, function(\Iterator $iterator) use ($callback) {
             $callback($iterator->current(), $iterator->key(), $iterator, $this);
             return true;
         }, [$input]);
@@ -194,8 +194,8 @@ 
         // Rewind this temp file and compare it with the specified file.
         $identical = true;
         $tempFile->fseek(0);
-        while(!$file->eof()) {
-            if($file->fread(8192) != $tempFile->fread(8192)) {
+        while (!$file->eof()) {
+            if ($file->fread(8192) != $tempFile->fread(8192)) {
                 $identical = false;
                 break;
             }

src/GlobIterator.php

Spacing +2 added lines, -2 removed lines

@@ -36,7 +36,7 @@ 
         $realPath = $path ? $path : './';
         $realPath = rtrim($realPath, '/') . '/';
 
-        $flags = $flags &~ \FilesystemIterator::CURRENT_AS_PATHNAME;
+        $flags = $flags & ~ \FilesystemIterator::CURRENT_AS_PATHNAME;
         $flags |= \FilesystemIterator::KEY_AS_PATHNAME;
         $iterator = new \RecursiveDirectoryIterator($realPath, $flags);
 
@@ -57,7 +57,7 @@ 
         GlobIteratorFileInfo::setPath($iteratorId, $path, $realPath);
 
         // Actual glob filtering.
-        $fIterator = new \CallbackFilterIterator($rIterator, function (&$current, &$key, $iterator) use ($iteratorId, $regexPattern) {
+        $fIterator = new \CallbackFilterIterator($rIterator, function(&$current, &$key, $iterator) use ($iteratorId, $regexPattern) {
             GlobIteratorFileInfo::setIteratorId($iteratorId);
             $fileInfo = $current->getFileInfo(GlobIteratorFileInfo::class);
             if ($this->flags & \FilesystemIterator::CURRENT_AS_PATHNAME) {

src/Iterator.php

Spacing +7 added lines, -7 removed lines

@@ -33,7 +33,7 @@ 
     public static function reduce(\Traversable $iterator, callable $callback, $initial = null)
     {
         $callback = \Closure::fromCallable($callback);
-        iterator_apply($iterator, function ($iterator) use (&$initial, $callback) {
+        iterator_apply($iterator, function($iterator) use (&$initial, $callback) {
             $initial = $callback($initial, $iterator->current(), $iterator->key());
             return true;
         }, [$iterator]);
@@ -42,14 +42,14 @@ 
 
     public static function sum(\Traversable $iterator)
     {
-        return self::reduce($iterator, function ($carry, $value, $key) {
+        return self::reduce($iterator, function($carry, $value, $key) {
             return $carry + $value;
         }, 0);
     }
 
     public static function product(\Traversable $iterator)
     {
-        return self::reduce($iterator, function ($carry, $value, $key) {
+        return self::reduce($iterator, function($carry, $value, $key) {
             return $carry * $value;
         }, 1);
     }
@@ -61,28 +61,28 @@ 
 
     public static function min(\Traversable $iterator)
     {
-        return self::reduce($iterator, function ($carry, $value, $key) {
+        return self::reduce($iterator, function($carry, $value, $key) {
             return $carry < $value ? $carry : $value;
         }, INF);
     }
 
     public static function max(\Traversable $iterator)
     {
-        return self::reduce($iterator, function ($carry, $value, $key) {
+        return self::reduce($iterator, function($carry, $value, $key) {
             return $carry > $value ? $carry : $value;
         }, -INF);
     }
 
     public static function concatenate(\Traversable $iterator)
     {
-        return self::reduce($iterator, function ($carry, $value, $key) {
+        return self::reduce($iterator, function($carry, $value, $key) {
             return $carry . $value;
         }, '');
     }
 
     public static function implode($separator, \Traversable $iterator)
     {
-        $result = self::reduce($iterator, function ($carry, $value, $key) use ($separator) {
+        $result = self::reduce($iterator, function($carry, $value, $key) use ($separator) {
             return $carry . $value . $separator;
         }, '');
         $result = mb_substr($result, 0, -mb_strlen($separator));

src/AtomicTempFileObjects.php

Spacing +2 added lines, -2 removed lines

@@ -103,7 +103,7 @@ 
     public function splitCsvFile(\Iterator $input, callable $callback)
     {
         $callback = \Closure::fromCallable($callback);
-        $this->process($input, function ($row, $rowNum, $input, $output) use ($callback) {
+        $this->process($input, function($row, $rowNum, $input, $output) use ($callback) {
             if ($fileName = $callback($row)) {
                 if (!$output->isFileOpen($fileName)) {
                     $output->openFile($fileName)->fputcsv(array_keys($row));
@@ -126,7 +126,7 @@ 
     {
         $callback = \Closure::fromCallable($callback);
         $input->rewind();
-        iterator_apply($input, function (\Iterator $iterator) use ($callback) {
+        iterator_apply($input, function(\Iterator $iterator) use ($callback) {
             $callback($iterator->current(), $iterator->key(), $iterator, $this);
             return true;
         }, [$input]);

src/ChunkIterator.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
 
         // The outer iterator is a finite replaceable iterator with a condition
         // on the inner iterator not being empty.
-        parent::__construct(new InfiniteIterator(new ReplaceableIterator(), function ($iterator) {
+        parent::__construct(new InfiniteIterator(new ReplaceableIterator(), function($iterator) {
             return !$iterator->current()->valid();
         }));
     }