gielfeldt / iterators

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

Doc Comments +3 added lines

@@ -12,6 +12,9 @@
         parent::__construct($this->getShuffledIterator($iterator));
     }
 
+    /**
+     * @param \Traversable $iterator
+     */
     public function getShuffledIterator($iterator)
     {
         $sortedIterator = new \ArrayIterator();

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