@@ -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; |