Failed Conditions
Push — master ( 12bd2a...8e4b2b )
by Igor
03:12
created
src/Transport/Http.php 1 patch
Spacing   +19 added lines, -19 removed lines patch added patch discarded remove patch
@@ -92,8 +92,8 @@  discard block
 block discarded – undo
92 92
     /**
93 93
      * @param CurlerRolling $curler
94 94
      */
95
-    public function setDirtyCurler(CurlerRolling $curler){
96
-        if ($curler instanceof  CurlerRolling){
95
+    public function setDirtyCurler(CurlerRolling $curler) {
96
+        if ($curler instanceof  CurlerRolling) {
97 97
             $this->_curler = $curler;
98 98
         }
99 99
     }
@@ -129,10 +129,10 @@  discard block
 block discarded – undo
129 129
             $proto = 'https';
130 130
         }
131 131
         $uri = $proto . '://' . $this->_host;
132
-        if (stripos($this->_host,'/')!==false || stripos($this->_host,':')!==false) {
132
+        if (stripos($this->_host, '/') !== false || stripos($this->_host, ':') !== false) {
133 133
             return $uri;
134 134
         }
135
-        if (intval($this->_port)>0) {
135
+        if (intval($this->_port) > 0) {
136 136
             return $uri . ':' . $this->_port;
137 137
         }
138 138
         return $uri;
@@ -204,7 +204,7 @@  discard block
 block discarded – undo
204 204
         }
205 205
 
206 206
         $new->timeOut($this->settings()->getTimeOut());
207
-        $new->connectTimeOut($this->_connectTimeOut);//->keepAlive(); // one sec
207
+        $new->connectTimeOut($this->_connectTimeOut); //->keepAlive(); // one sec
208 208
         $new->verbose(boolval($this->_verbose));
209 209
 
210 210
         return $new;
@@ -257,7 +257,7 @@  discard block
 block discarded – undo
257 257
     {
258 258
 
259 259
         if ($sql instanceof Query) {
260
-            $query=$sql;
260
+            $query = $sql;
261 261
         } else {
262 262
             $query = new Query($sql);
263 263
         }
@@ -619,10 +619,10 @@  discard block
 block discarded – undo
619 619
      * @return Statement
620 620
      * @throws \ClickHouseDB\Exception\TransportException
621 621
      */
622
-    private function streaming(Stream $streamRW,CurlerRequest $request)
622
+    private function streaming(Stream $streamRW, CurlerRequest $request)
623 623
     {
624
-        $callable=$streamRW->getClosure();
625
-        $stream=$streamRW->getStream();
624
+        $callable = $streamRW->getClosure();
625
+        $stream = $streamRW->getStream();
626 626
 
627 627
 
628 628
 
@@ -633,11 +633,11 @@  discard block
 block discarded – undo
633 633
                 if ($streamRW->isWrite())
634 634
                 {
635 635
 
636
-                    $callable = function ($ch, $fd, $length) use ($stream) {
636
+                    $callable = function($ch, $fd, $length) use ($stream) {
637 637
                         return ($line = fread($stream, $length)) ? $line : '';
638 638
                     };
639 639
                 } else {
640
-                    $callable = function ($ch, $fd) use ($stream) {
640
+                    $callable = function($ch, $fd) use ($stream) {
641 641
                         return fwrite($stream, $fd);
642 642
                     };
643 643
                 }
@@ -672,7 +672,7 @@  discard block
 block discarded – undo
672 672
             }
673 673
 
674 674
 
675
-            $this->_curler->execOne($request,true);
675
+            $this->_curler->execOne($request, true);
676 676
             $response = new Statement($request);
677 677
             if ($response->isError()) {
678 678
                 $response->error();
@@ -694,11 +694,11 @@  discard block
 block discarded – undo
694 694
      * @return Statement
695 695
      * @throws \ClickHouseDB\Exception\TransportException
696 696
      */
697
-    public function streamRead(Stream $streamRead,$sql,$bindings=[])
697
+    public function streamRead(Stream $streamRead, $sql, $bindings = [])
698 698
     {
699
-        $sql=$this->prepareQuery($sql,$bindings);
700
-        $request=$this->getRequestRead($sql);
701
-        return $this->streaming($streamRead,$request);
699
+        $sql = $this->prepareQuery($sql, $bindings);
700
+        $request = $this->getRequestRead($sql);
701
+        return $this->streaming($streamRead, $request);
702 702
 
703 703
     }
704 704
 
@@ -709,10 +709,10 @@  discard block
 block discarded – undo
709 709
      * @return Statement
710 710
      * @throws \ClickHouseDB\Exception\TransportException
711 711
      */
712
-    public function streamWrite(Stream $streamWrite,$sql,$bindings=[])
712
+    public function streamWrite(Stream $streamWrite, $sql, $bindings = [])
713 713
     {
714
-        $sql=$this->prepareQuery($sql,$bindings);
714
+        $sql = $this->prepareQuery($sql, $bindings);
715 715
         $request = $this->writeStreamData($sql);
716
-        return $this->streaming($streamWrite,$request);
716
+        return $this->streaming($streamWrite, $request);
717 717
     }
718 718
 }
Please login to merge, or discard this patch.