@@ -22,7 +22,7 @@ discard block |
||
22 | 22 | */ |
23 | 23 | private $degenerations = []; |
24 | 24 | |
25 | - private $supportFormats=[ |
|
25 | + private $supportFormats = [ |
|
26 | 26 | "FORMAT\\s+TSVRaw", |
27 | 27 | "FORMAT\\s+TSVWithNamesAndTypes", |
28 | 28 | "FORMAT\\s+TSVWithNames", |
@@ -71,7 +71,7 @@ discard block |
||
71 | 71 | if (null === $this->format) { |
72 | 72 | return false; |
73 | 73 | } |
74 | - $supportFormats = implode("|",$this->supportFormats); |
|
74 | + $supportFormats = implode("|", $this->supportFormats); |
|
75 | 75 | |
76 | 76 | $this->sql = trim($this->sql); |
77 | 77 | if (substr($this->sql, -1) == ';') { |
@@ -260,7 +260,7 @@ discard block |
||
260 | 260 | } |
261 | 261 | |
262 | 262 | $new->timeOut($this->settings()->getTimeOut()); |
263 | - $new->connectTimeOut($this->_connectTimeOut);//->keepAlive(); // one sec |
|
263 | + $new->connectTimeOut($this->_connectTimeOut); //->keepAlive(); // one sec |
|
264 | 264 | $new->verbose(boolval($this->_verbose)); |
265 | 265 | |
266 | 266 | return $new; |
@@ -371,7 +371,7 @@ discard block |
||
371 | 371 | |
372 | 372 | $request->url($url); |
373 | 373 | |
374 | - $request->setCallbackFunction(function (CurlerRequest $request) { |
|
374 | + $request->setCallbackFunction(function(CurlerRequest $request) { |
|
375 | 375 | $handle = $request->getInfileHandle(); |
376 | 376 | if (is_resource($handle)) { |
377 | 377 | fclose($handle); |
@@ -510,7 +510,7 @@ discard block |
||
510 | 510 | } |
511 | 511 | |
512 | 512 | |
513 | - $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function (CurlerRequest $request) { |
|
513 | + $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function(CurlerRequest $request) { |
|
514 | 514 | fclose($request->getResultFileHandle()); |
515 | 515 | }); |
516 | 516 | } |
@@ -697,11 +697,11 @@ discard block |
||
697 | 697 | if (!is_callable($callable)) { |
698 | 698 | if ($streamRW->isWrite()) { |
699 | 699 | |
700 | - $callable = function ($ch, $fd, $length) use ($stream) { |
|
700 | + $callable = function($ch, $fd, $length) use ($stream) { |
|
701 | 701 | return ($line = fread($stream, $length)) ? $line : ''; |
702 | 702 | }; |
703 | 703 | } else { |
704 | - $callable = function ($ch, $fd) use ($stream) { |
|
704 | + $callable = function($ch, $fd) use ($stream) { |
|
705 | 705 | return fwrite($stream, $fd); |
706 | 706 | }; |
707 | 707 | } |
@@ -290,9 +290,9 @@ discard block |
||
290 | 290 | |
291 | 291 | |
292 | 292 | if (is_object($done['handle'])) { |
293 | - $key = spl_object_id( $done['handle'] ); |
|
293 | + $key = spl_object_id($done['handle']); |
|
294 | 294 | } else { |
295 | - $key = (string) $done['handle'] ; |
|
295 | + $key = (string) $done['handle']; |
|
296 | 296 | } |
297 | 297 | |
298 | 298 | $task_id = $this->handleMapTasks[$key]; |
@@ -374,9 +374,9 @@ discard block |
||
374 | 374 | curl_multi_add_handle($this->handlerMulti(), $h); |
375 | 375 | |
376 | 376 | if (is_object($h)) { |
377 | - $key = spl_object_id( $h ); |
|
377 | + $key = spl_object_id($h); |
|
378 | 378 | } else { |
379 | - $key = (string) $h ; |
|
379 | + $key = (string) $h; |
|
380 | 380 | } |
381 | 381 | |
382 | 382 | $this->handleMapTasks[$key] = $task_id; |