ytake / php-presto-client

src/StatementClient.php

Spacing +7 added lines, -7 removed lines

@@ -94,8 +94,8 @@ 
         $this->headers = array_merge(
             [
                 PrestoHeaders::PRESTO_USER => $this->session->getUser(),
-                'User-Agent'               => $this->session->getSource() . '/' . PrestoHeaders::VERSION,
-                'Authorization'            => 'Basic ' . base64_encode($this->session->getUsername() . ':' . $this->session->getPassword()),
+                'User-Agent'               => $this->session->getSource().'/'.PrestoHeaders::VERSION,
+                'Authorization'            => 'Basic '.base64_encode($this->session->getUsername().':'.$this->session->getPassword()),
             ],
             $this->session->getHeader()
         );
@@ -119,7 +119,7 @@ 
             $sessions = [];
             /** @var Property $property */
             foreach ($sessionProperty as $property) {
-                $sessions[] = $property->getKey() . '=' . $property->getValue();
+                $sessions[] = $property->getKey().'='.$property->getValue();
             }
             $request = $request->withAddedHeader(
                 PrestoHeaders::PRESTO_SESSION,
@@ -131,7 +131,7 @@ 
             $statements = [];
             foreach ($preparedStatements as $preparedStatement) {
                 $statements[] = urlencode($preparedStatement->getKey())
-                    . '=' . urlencode($preparedStatement->getValue());
+                    . '='.urlencode($preparedStatement->getValue());
             }
             $request = $request->withAddedHeader(
                 PrestoHeaders::PRESTO_PREPARED_STATEMENT,
@@ -152,7 +152,7 @@ 
     public function execute(int $timeout = 500000, bool $debug = false)
     {
         $normalize = UriNormalizer::normalize(
-            new Uri($this->session->getHost() . StatementClient::STATEMENT_URI),
+            new Uri($this->session->getHost().StatementClient::STATEMENT_URI),
             UriNormalizer::REMOVE_DUPLICATE_SLASHES
         );
         $request = new Request(RequestMethodInterface::METHOD_POST, $normalize, $this->headers);
@@ -212,9 +212,9 @@ 
                 'timeout' => $timeout,
                 'debug'   => $debug,
             ]);
-            $promise->then(function (ResponseInterface $response) {
+            $promise->then(function(ResponseInterface $response) {
                 $this->fulfilled = (StatusCodeInterface::STATUS_NO_CONTENT === $response->getStatusCode());
-            }, function (RequestException $e) {
+            }, function(RequestException $e) {
                 throw new RequestFailedException($e->getMessage(), $e->getCode(), $e);
             });
             $promise->wait();