@@ -692,7 +692,7 @@ |
||
692 | 692 | * |
693 | 693 | * @param string $data The data to check |
694 | 694 | * |
695 | - * @return bool Whether the data is quoted or not |
|
695 | + * @return integer Whether the data is quoted or not |
|
696 | 696 | */ |
697 | 697 | protected function isQuoted($data) |
698 | 698 | { |
@@ -513,12 +513,12 @@ discard block |
||
513 | 513 | return $this->guessDelimByDistribution($decision, $eol); |
514 | 514 | } catch (TasterException $e) { |
515 | 515 | // if somehow we STILL can't come to a consensus, then fall back to a |
516 | - // "preferred delimiters" list... |
|
517 | - foreach ($this->delims as $key => $chr) { |
|
518 | - if (collect($decision)->contains($chr)) { |
|
519 | - return $chr; |
|
520 | - } |
|
521 | - } |
|
516 | + // "preferred delimiters" list... |
|
517 | + foreach ($this->delims as $key => $chr) { |
|
518 | + if (collect($decision)->contains($chr)) { |
|
519 | + return $chr; |
|
520 | + } |
|
521 | + } |
|
522 | 522 | } |
523 | 523 | } |
524 | 524 | |
@@ -588,8 +588,8 @@ discard block |
||
588 | 588 | })->map(function ($dists) { |
589 | 589 | return $dists->average(); |
590 | 590 | })->sort() |
591 | - ->reverse() |
|
592 | - ->getKeyAtPosition(0)]; |
|
591 | + ->reverse() |
|
592 | + ->getKeyAtPosition(0)]; |
|
593 | 593 | } catch (Exception $e) { |
594 | 594 | throw new TasterException('delimiter cannot be determined by distribution', TasterException::ERR_DELIMITER); |
595 | 595 | } |
@@ -15,12 +15,10 @@ |
||
15 | 15 | |
16 | 16 | use CSVelte\Collection\AbstractCollection; |
17 | 17 | use CSVelte\Collection\CharCollection; |
18 | -use CSVelte\Collection\Collection; |
|
19 | 18 | use CSVelte\Collection\NumericCollection; |
20 | 19 | use CSVelte\Collection\TabularCollection; |
21 | 20 | use CSVelte\Contract\Streamable; |
22 | 21 | use CSVelte\Exception\TasterException; |
23 | - |
|
24 | 22 | use DateTime; |
25 | 23 | use Exception; |
26 | 24 | use OutOfBoundsException; |
@@ -232,12 +232,12 @@ discard block |
||
232 | 232 | $types = new TabularCollection(); |
233 | 233 | |
234 | 234 | // callback to build the aforementioned collection |
235 | - $buildTypes = function ($line, $line_no) use ($types, $delim, $eol) { |
|
235 | + $buildTypes = function($line, $line_no) use ($types, $delim, $eol) { |
|
236 | 236 | if ($line_no > 2) { |
237 | 237 | return; |
238 | 238 | } |
239 | 239 | $line = str_replace(self::PLACEHOLDER_NEWLINE, $eol, $line); |
240 | - $getType = function ($field, $colpos) use ($types, $line, $line_no, $delim) { |
|
240 | + $getType = function($field, $colpos) use ($types, $line, $line_no, $delim) { |
|
241 | 241 | $field = str_replace(self::PLACEHOLDER_DELIM, $delim, $field); |
242 | 242 | $fieldMeta = [ |
243 | 243 | 'value' => $field, |
@@ -264,8 +264,8 @@ discard block |
||
264 | 264 | |
265 | 265 | $hasHeader = new NumericCollection(); |
266 | 266 | $possibleHeader = collect($types->shift()); |
267 | - $types->walk(function (AbstractCollection $row) use ($hasHeader, $possibleHeader) { |
|
268 | - $row->walk(function (AbstractCollection $fieldMeta, $col_no) use ($hasHeader, $possibleHeader) { |
|
267 | + $types->walk(function(AbstractCollection $row) use ($hasHeader, $possibleHeader) { |
|
268 | + $row->walk(function(AbstractCollection $fieldMeta, $col_no) use ($hasHeader, $possibleHeader) { |
|
269 | 269 | try { |
270 | 270 | $col = collect($possibleHeader->get($col_no, null, true)); |
271 | 271 | if ($fieldMeta->get('type') == self::TYPE_STRING) { |
@@ -329,9 +329,9 @@ discard block |
||
329 | 329 | { |
330 | 330 | $str = $this->removeQuotedStrings($this->sample); |
331 | 331 | $eols = [ |
332 | - self::EOL_WINDOWS => "\r\n", // 0x0D - 0x0A - Windows, DOS OS/2 |
|
333 | - self::EOL_UNIX => "\n", // 0x0A - - Unix, OSX |
|
334 | - self::EOL_TRS80 => "\r", // 0x0D - - Apple ][, TRS80 |
|
332 | + self::EOL_WINDOWS => "\r\n", // 0x0D - 0x0A - Windows, DOS OS/2 |
|
333 | + self::EOL_UNIX => "\n", // 0x0A - - Unix, OSX |
|
334 | + self::EOL_TRS80 => "\r", // 0x0D - - Apple ][, TRS80 |
|
335 | 335 | ]; |
336 | 336 | |
337 | 337 | $curCount = 0; |
@@ -374,12 +374,12 @@ discard block |
||
374 | 374 | $patterns = []; |
375 | 375 | // delim can be anything but line breaks, quotes, alphanumeric, underscore, backslash, or any type of spaces |
376 | 376 | $antidelims = implode(["\r", "\n", "\w", preg_quote('"', '/'), preg_quote("'", '/'), preg_quote(chr(self::SPACE), '/')]); |
377 | - $delim = '(?P<delim>[^' . $antidelims . '])'; |
|
377 | + $delim = '(?P<delim>[^'.$antidelims.'])'; |
|
378 | 378 | $quote = '(?P<quoteChar>"|\'|`)'; // @todo I think MS Excel uses some strange encoding for fancy open/close quotes |
379 | - $patterns[] = '/' . $delim . ' ?' . $quote . '.*?\2\1/ms'; // ,"something", - anything but whitespace or quotes followed by a possible space followed by a quote followed by anything followed by same quote, followed by same anything but whitespace |
|
380 | - $patterns[] = '/(?:^|\n)' . $quote . '.*?\1' . $delim . ' ?/ms'; // 'something', - beginning of line or line break, followed by quote followed by anything followed by quote followed by anything but whitespace or quotes |
|
381 | - $patterns[] = '/' . $delim . ' ?' . $quote . '.*?\2(?:^|\n)/ms'; // ,'something' - anything but whitespace or quote followed by possible space followed by quote followed by anything followed by quote, followed by end of line |
|
382 | - $patterns[] = '/(?:^|\n)' . $quote . '.*?\2(?:$|\n)/ms'; // 'something' - beginning of line followed by quote followed by anything followed by quote followed by same quote followed by end of line |
|
379 | + $patterns[] = '/'.$delim.' ?'.$quote.'.*?\2\1/ms'; // ,"something", - anything but whitespace or quotes followed by a possible space followed by a quote followed by anything followed by same quote, followed by same anything but whitespace |
|
380 | + $patterns[] = '/(?:^|\n)'.$quote.'.*?\1'.$delim.' ?/ms'; // 'something', - beginning of line or line break, followed by quote followed by anything followed by quote followed by anything but whitespace or quotes |
|
381 | + $patterns[] = '/'.$delim.' ?'.$quote.'.*?\2(?:^|\n)/ms'; // ,'something' - anything but whitespace or quote followed by possible space followed by quote followed by anything followed by quote, followed by end of line |
|
382 | + $patterns[] = '/(?:^|\n)'.$quote.'.*?\2(?:$|\n)/ms'; // 'something' - beginning of line followed by quote followed by anything followed by quote followed by same quote followed by end of line |
|
383 | 383 | foreach ($patterns as $pattern) { |
384 | 384 | // @todo I had to add the error suppression char here because it was |
385 | 385 | // causing undefined offset errors with certain data sets. strange... |
@@ -430,15 +430,15 @@ discard block |
||
430 | 430 | // each frequency (in 10 lines, "tab" occurred 5 times on 7 of those |
431 | 431 | // lines, 6 times on 2 lines, and 7 times on 1 line) |
432 | 432 | collect(explode($eol, $this->removeQuotedStrings($this->sample))) |
433 | - ->walk(function ($line, $line_no) use ($frequencies) { |
|
433 | + ->walk(function($line, $line_no) use ($frequencies) { |
|
434 | 434 | collect(str_split($line)) |
435 | - ->filter(function ($c) { |
|
435 | + ->filter(function($c) { |
|
436 | 436 | return collect($this->delims)->contains($c); |
437 | 437 | }) |
438 | 438 | ->frequency() |
439 | 439 | ->sort() |
440 | 440 | ->reverse() |
441 | - ->walk(function ($count, $char) use ($frequencies, $line_no) { |
|
441 | + ->walk(function($count, $char) use ($frequencies, $line_no) { |
|
442 | 442 | try { |
443 | 443 | $char_counts = $frequencies->get($char, null, true); |
444 | 444 | } catch (OutOfBoundsException $e) { |
@@ -451,8 +451,8 @@ discard block |
||
451 | 451 | // the above only finds frequencies for characters if they exist in |
452 | 452 | // a given line. This will go back and fill in zeroes where a char |
453 | 453 | // didn't occur at all in a given line (needed to determine mode) |
454 | - ->walk(function ($line, $line_no) use ($frequencies) { |
|
455 | - $frequencies->walk(function ($counts, $char) use ($line_no, $frequencies) { |
|
454 | + ->walk(function($line, $line_no) use ($frequencies) { |
|
455 | + $frequencies->walk(function($counts, $char) use ($line_no, $frequencies) { |
|
456 | 456 | try { |
457 | 457 | $char_counts = $frequencies->get($char, null, true); |
458 | 458 | } catch (OutOfBoundsException $e) { |
@@ -471,8 +471,8 @@ discard block |
||
471 | 471 | foreach ($frequencies as $char => $freq) { |
472 | 472 | $modes->set($char, (new NumericCollection($freq))->mode()); |
473 | 473 | } |
474 | - $frequencies->walk(function ($f, $chr) use ($modes, $consistencies) { |
|
475 | - collect($f)->walk(function ($num) use ($modes, $chr, $consistencies) { |
|
474 | + $frequencies->walk(function($f, $chr) use ($modes, $consistencies) { |
|
475 | + collect($f)->walk(function($num) use ($modes, $chr, $consistencies) { |
|
476 | 476 | if ($expected = $modes->get($chr)) { |
477 | 477 | if ($num == $expected) { |
478 | 478 | // met the goal, yay! |
@@ -563,19 +563,19 @@ discard block |
||
563 | 563 | // @todo Write a method that does this... |
564 | 564 | $lines = collect(explode($eol, $this->removeQuotedStrings($this->sample))); |
565 | 565 | |
566 | - return $delims[collect($delims)->map(function ($delim) use (&$distrib, $lines) { |
|
566 | + return $delims[collect($delims)->map(function($delim) use (&$distrib, $lines) { |
|
567 | 567 | $linedist = collect(); |
568 | - $lines->walk(function ($line, $line_no) use (&$linedist, $delim) { |
|
568 | + $lines->walk(function($line, $line_no) use (&$linedist, $delim) { |
|
569 | 569 | if (!strlen($line)) { |
570 | 570 | return; |
571 | 571 | } |
572 | 572 | $sectstot = 10; |
573 | 573 | $sectlen = (int) (strlen($line) / $sectstot); |
574 | 574 | $sections = collect(str_split($line, $sectlen)) |
575 | - ->map(function ($section) use ($delim) { |
|
575 | + ->map(function($section) use ($delim) { |
|
576 | 576 | return substr_count($section, $delim); |
577 | 577 | }) |
578 | - ->filter(function ($count) { |
|
578 | + ->filter(function($count) { |
|
579 | 579 | return (bool) $count; |
580 | 580 | }); |
581 | 581 | if (is_numeric($count = $sections->count())) { |
@@ -584,7 +584,7 @@ discard block |
||
584 | 584 | }); |
585 | 585 | |
586 | 586 | return $linedist; |
587 | - })->map(function ($dists) { |
|
587 | + })->map(function($dists) { |
|
588 | 588 | return $dists->average(); |
589 | 589 | })->sort() |
590 | 590 | ->reverse() |
@@ -634,9 +634,9 @@ discard block |
||
634 | 634 | |
635 | 635 | // walk through each line from the data sample to determine which fields |
636 | 636 | // are quoted and which aren't |
637 | - $qsFunc = function ($line) use (&$quoting_styles, &$freq, $eol, $delim) { |
|
637 | + $qsFunc = function($line) use (&$quoting_styles, &$freq, $eol, $delim) { |
|
638 | 638 | $line = str_replace(self::PLACEHOLDER_NEWLINE, $eol, $line); |
639 | - $qnqaFunc = function ($field) use (&$quoting_styles, &$freq, $delim) { |
|
639 | + $qnqaFunc = function($field) use (&$quoting_styles, &$freq, $delim) { |
|
640 | 640 | $field = str_replace(self::PLACEHOLDER_DELIM, $delim, $field); |
641 | 641 | if ($this->isQuoted($field)) { |
642 | 642 | $field = $this->unQuote($field); |
@@ -657,7 +657,7 @@ discard block |
||
657 | 657 | $lines->walk($qsFunc->bindTo($this)); |
658 | 658 | |
659 | 659 | $types = $freq->get('quoted')->unique(); |
660 | - $quoting_styles = $quoting_styles->filter(function ($val) { |
|
660 | + $quoting_styles = $quoting_styles->filter(function($val) { |
|
661 | 661 | return (bool) $val; |
662 | 662 | }); |
663 | 663 | // if quoting_styles still has QUOTE_ALL or QUOTE_NONE, then return |
@@ -677,7 +677,7 @@ discard block |
||
677 | 677 | if ($types->contains(self::DATA_NONNUMERIC)) { |
678 | 678 | // allow for a SMALL amount of error here |
679 | 679 | $counts = collect([self::DATA_SPECIAL => 0, self::DATA_NONNUMERIC => 0]); |
680 | - $freq->get('quoted')->walk(function ($type) use (&$counts) { |
|
680 | + $freq->get('quoted')->walk(function($type) use (&$counts) { |
|
681 | 681 | $counts->increment($type); |
682 | 682 | }); |
683 | 683 | // @todo is all this even necessary? seems unnecessary to me... |
@@ -770,7 +770,7 @@ discard block |
||
770 | 770 | */ |
771 | 771 | protected function replaceQuotedSpecialChars($data, $delim) |
772 | 772 | { |
773 | - return preg_replace_callback('/([\'"])(.*)\1/imsU', function ($matches) use ($delim) { |
|
773 | + return preg_replace_callback('/([\'"])(.*)\1/imsU', function($matches) use ($delim) { |
|
774 | 774 | $ret = preg_replace("/([\r\n])/", self::PLACEHOLDER_NEWLINE, $matches[0]); |
775 | 775 | $ret = str_replace($delim, self::PLACEHOLDER_DELIM, $ret); |
776 | 776 | |
@@ -810,7 +810,7 @@ discard block |
||
810 | 810 | $day = '[0-3]?[0-9]'; |
811 | 811 | $sep = '[\/\.\-]?'; |
812 | 812 | $time = '([0-2]?[0-9](:[0-5][0-9]){1,2}(am|pm)?|[01]?[0-9](am|pm))'; |
813 | - $date = '(' . $month . $sep . $day . $sep . $year . '|' . $day . $sep . $month . $sep . $year . '|' . $year . $sep . $month . $sep . $day . ')'; |
|
813 | + $date = '('.$month.$sep.$day.$sep.$year.'|'.$day.$sep.$month.$sep.$year.'|'.$year.$sep.$month.$sep.$day.')'; |
|
814 | 814 | $dt = new DateTime($data); |
815 | 815 | $dt->setTime(0, 0, 0); |
816 | 816 | $now = new DateTime(); |
@@ -254,7 +254,7 @@ discard block |
||
254 | 254 | */ |
255 | 255 | public function toArray() |
256 | 256 | { |
257 | - return array_map(function ($row) { |
|
257 | + return array_map(function($row) { |
|
258 | 258 | return $row->toArray(); |
259 | 259 | }, iterator_to_array($this)); |
260 | 260 | } |
@@ -387,12 +387,12 @@ discard block |
||
387 | 387 | if (!isset($i)) { |
388 | 388 | $i = 0; |
389 | 389 | } |
390 | - $c = $line[$i++]; |
|
390 | + $c = $line[$i++]; |
|
391 | 391 | if ($this->escape) { |
392 | 392 | $this->escape = false; |
393 | 393 | continue; |
394 | 394 | } |
395 | - $this->escape = ($c == $escapeChar); |
|
395 | + $this->escape = ($c == $escapeChar); |
|
396 | 396 | if ($c == $quoteChar) { |
397 | 397 | $this->open = !$this->open; |
398 | 398 | } |
@@ -428,7 +428,7 @@ discard block |
||
428 | 428 | */ |
429 | 429 | protected function replaceQuotedSpecialChars($data, $delim, $quo, $eol) |
430 | 430 | { |
431 | - return preg_replace_callback('/([' . preg_quote($quo, '/') . '])(.*)\1/imsU', function ($matches) use ($delim, $eol) { |
|
431 | + return preg_replace_callback('/(['.preg_quote($quo, '/').'])(.*)\1/imsU', function($matches) use ($delim, $eol) { |
|
432 | 432 | $ret = str_replace($eol, self::PLACEHOLDER_NEWLINE, $matches[0]); |
433 | 433 | $ret = str_replace($delim, self::PLACEHOLDER_DELIM, $ret); |
434 | 434 | |
@@ -453,7 +453,7 @@ discard block |
||
453 | 453 | protected function undoReplaceQuotedSpecialChars($data, $delim, $eol) |
454 | 454 | { |
455 | 455 | $replacements = [self::PLACEHOLDER_DELIM => $delim, self::PLACEHOLDER_NEWLINE => $eol]; |
456 | - if (array_walk($replacements, function ($replacement, $placeholder) use (&$data) { |
|
456 | + if (array_walk($replacements, function($replacement, $placeholder) use (&$data) { |
|
457 | 457 | $data = str_replace($placeholder, $replacement, $data); |
458 | 458 | })) { |
459 | 459 | return $data; |
@@ -497,7 +497,7 @@ discard block |
||
497 | 497 | */ |
498 | 498 | protected function unEscape($str, $esc, $quo) |
499 | 499 | { |
500 | - return str_replace($esc . $quo, $quo, $str); |
|
500 | + return str_replace($esc.$quo, $quo, $str); |
|
501 | 501 | } |
502 | 502 | |
503 | 503 | /** |
@@ -516,7 +516,7 @@ discard block |
||
516 | 516 | $columns = explode($f->delimiter, $replaced); |
517 | 517 | $that = $this; |
518 | 518 | |
519 | - return array_map(function ($val) use ($that, $f) { |
|
519 | + return array_map(function($val) use ($that, $f) { |
|
520 | 520 | $undone = $that->undoReplaceQuotedSpecialChars($val, $f->delimiter, $f->lineTerminator); |
521 | 521 | |
522 | 522 | return $this->unQuote($undone); |
@@ -242,7 +242,7 @@ |
||
242 | 242 | } elseif ($fields instanceof Iterator) { |
243 | 243 | $fields = iterator_to_array($fields); |
244 | 244 | } else { |
245 | - throw new InvalidArgumentException(__CLASS__ . ' requires an array, got: ' . gettype($fields)); |
|
245 | + throw new InvalidArgumentException(__CLASS__.' requires an array, got: '.gettype($fields)); |
|
246 | 246 | } |
247 | 247 | } |
248 | 248 | $this->fields = collect(array_values($fields)); |
@@ -70,11 +70,11 @@ discard block |
||
70 | 70 | if (in_array($rp, $paths)) { |
71 | 71 | return true; |
72 | 72 | } |
73 | - $this->paths []= $rp; |
|
73 | + $this->paths [] = $rp; |
|
74 | 74 | |
75 | 75 | return true; |
76 | 76 | } |
77 | - $this->paths []= $path; |
|
77 | + $this->paths [] = $path; |
|
78 | 78 | |
79 | 79 | return false; |
80 | 80 | } |
@@ -132,7 +132,7 @@ discard block |
||
132 | 132 | $fqcp = str_replace(self::NAMESPACE_SEPARATOR, DIRECTORY_SEPARATOR, $className); |
133 | 133 | $paths = $this->getPaths(); |
134 | 134 | foreach ($paths as $path) { |
135 | - $classPath = $path . DIRECTORY_SEPARATOR . $fqcp . '.php'; |
|
135 | + $classPath = $path.DIRECTORY_SEPARATOR.$fqcp.'.php'; |
|
136 | 136 | if (file_exists($classPath) && is_readable($classPath)) { |
137 | 137 | require_once($classPath); |
138 | 138 |
@@ -114,7 +114,7 @@ discard block |
||
114 | 114 | if (is_array($headers)) { |
115 | 115 | $headers = new ArrayIterator($headers); |
116 | 116 | } |
117 | - $this->headers = $headers; |
|
117 | + $this->headers = $headers; |
|
118 | 118 | |
119 | 119 | return $this; |
120 | 120 | } |
@@ -137,7 +137,7 @@ discard block |
||
137 | 137 | if (is_array($row)) { |
138 | 138 | $row = new ArrayIterator($row); |
139 | 139 | } |
140 | - $row = $this->prepareRow($row); |
|
140 | + $row = $this->prepareRow($row); |
|
141 | 141 | if ($count = $this->output->writeLine($row->join($delim), $eol)) { |
142 | 142 | $this->written++; |
143 | 143 | |
@@ -160,7 +160,7 @@ discard block |
||
160 | 160 | $rows = new ArrayIterator($rows); |
161 | 161 | } |
162 | 162 | if (!($rows instanceof Iterator)) { |
163 | - throw new InvalidArgumentException('First argument for ' . __METHOD__ . ' must be iterable'); |
|
163 | + throw new InvalidArgumentException('First argument for '.__METHOD__.' must be iterable'); |
|
164 | 164 | } |
165 | 165 | $written = 0; |
166 | 166 | if ($rows instanceof Reader) { |
@@ -203,7 +203,7 @@ discard block |
||
203 | 203 | { |
204 | 204 | $items = []; |
205 | 205 | foreach ($row as $data) { |
206 | - $items []= $this->prepareData($data); |
|
206 | + $items [] = $this->prepareData($data); |
|
207 | 207 | } |
208 | 208 | $row = new Row($items); |
209 | 209 | |
@@ -240,8 +240,8 @@ discard block |
||
240 | 240 | // Normally I would make this a method on the class, but I don't intend |
241 | 241 | // to use it for very long, in fact, once I finish writing the Data class |
242 | 242 | // it is gonezo! |
243 | - $hasSpecialChars = function ($s) use ($flvr) { |
|
244 | - $specialChars = preg_quote($flvr->lineTerminator . $flvr->quoteChar . $flvr->delimiter); |
|
243 | + $hasSpecialChars = function($s) use ($flvr) { |
|
244 | + $specialChars = preg_quote($flvr->lineTerminator.$flvr->quoteChar.$flvr->delimiter); |
|
245 | 245 | $pattern = "/[{$specialChars}]/m"; |
246 | 246 | |
247 | 247 | return preg_match($pattern, $s); |
@@ -289,6 +289,6 @@ discard block |
||
289 | 289 | $escapeQuote = ($flvr->doubleQuote) ? $flvr->quoteChar : $flvr->escapeChar; |
290 | 290 | } |
291 | 291 | // @todo Not sure what else, if anything, I'm supposed to be escaping here.. |
292 | - return str_replace($flvr->quoteChar, $escapeQuote . $flvr->quoteChar, $str); |
|
292 | + return str_replace($flvr->quoteChar, $escapeQuote.$flvr->quoteChar, $str); |
|
293 | 293 | } |
294 | 294 | } |
@@ -204,7 +204,7 @@ discard block |
||
204 | 204 | */ |
205 | 205 | public function __set($attr, $val) |
206 | 206 | { |
207 | - throw new ImmutableException('Cannot change attributes on an immutable object: ' . self::class . '::$' . $attr); |
|
207 | + throw new ImmutableException('Cannot change attributes on an immutable object: '.self::class.'::$'.$attr); |
|
208 | 208 | } |
209 | 209 | |
210 | 210 | /** |
@@ -270,7 +270,7 @@ discard block |
||
270 | 270 | protected function assertValidAttribute($attr) |
271 | 271 | { |
272 | 272 | if (!property_exists(self::class, $attr)) { |
273 | - throw new InvalidArgumentException('Unknown attribute: ' . $attr); |
|
273 | + throw new InvalidArgumentException('Unknown attribute: '.$attr); |
|
274 | 274 | } |
275 | 275 | } |
276 | 276 | } |
@@ -60,7 +60,7 @@ |
||
60 | 60 | } |
61 | 61 | $buffer .= $byte; |
62 | 62 | // Break when a new line is found or the max length - 1 is reached |
63 | - if (array_reduce($eol, function ($carry, $eol) use ($buffer) { |
|
63 | + if (array_reduce($eol, function($carry, $eol) use ($buffer) { |
|
64 | 64 | if (!$carry) { |
65 | 65 | $eollen = 0 - strlen($eol); |
66 | 66 |
@@ -82,7 +82,7 @@ |
||
82 | 82 | */ |
83 | 83 | public function toArray() |
84 | 84 | { |
85 | - return array_map(function ($row) { |
|
85 | + return array_map(function($row) { |
|
86 | 86 | return $row->toArray(); |
87 | 87 | }, iterator_to_array($this)); |
88 | 88 | } |
@@ -244,7 +244,7 @@ discard block |
||
244 | 244 | { |
245 | 245 | if (!$this->isConnected()) { |
246 | 246 | $e = null; |
247 | - $errhandler = function () use (&$e) { |
|
247 | + $errhandler = function() use (&$e) { |
|
248 | 248 | $e = new IOException(sprintf( |
249 | 249 | 'Could not open connection for %s using mode %s', |
250 | 250 | $this->getUri(), |
@@ -543,7 +543,7 @@ discard block |
||
543 | 543 | |
544 | 544 | return $this; |
545 | 545 | } |
546 | - throw new InvalidArgumentException('Context options must be an array, got: ' . gettype($options)); |
|
546 | + throw new InvalidArgumentException('Context options must be an array, got: '.gettype($options)); |
|
547 | 547 | } |
548 | 548 | |
549 | 549 | /** |
@@ -567,7 +567,7 @@ discard block |
||
567 | 567 | |
568 | 568 | return $this; |
569 | 569 | } |
570 | - throw new InvalidArgumentException('Context parameters must be an array, got: ' . gettype($params)); |
|
570 | + throw new InvalidArgumentException('Context parameters must be an array, got: '.gettype($params)); |
|
571 | 571 | } |
572 | 572 | |
573 | 573 | /** |
@@ -896,7 +896,7 @@ discard block |
||
896 | 896 | if (is_null($lazy)) { |
897 | 897 | $lazy = true; |
898 | 898 | } |
899 | - $this->lazy = (bool) $lazy; |
|
899 | + $this->lazy = (bool) $lazy; |
|
900 | 900 | |
901 | 901 | return $this; |
902 | 902 | } |