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

@@ -33,6 +33,9 @@
         return $sortedIterator;
     }
 
+    /**
+     * @param \Traversable $iterator
+     */
     protected function generateElement($key, $value, $iterator)
     {
         return (object) ['key' => $key, 'current' => $value];