ytake / php-presto-client

src/StatementClient.php

Spacing +6 added lines, -6 removed lines

@@ -94,7 +94,7 @@ 
         $this->headers = array_merge(
             [
                 PrestoHeaders::PRESTO_USER => $this->session->getUser(),
-                'User-Agent'               => $this->session->getSource() . '/' . PrestoHeaders::VERSION
+                'User-Agent'               => $this->session->getSource().'/'.PrestoHeaders::VERSION
             ],
             $this->session->getHeader()
         );
@@ -118,7 +118,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,
@@ -130,7 +130,7 @@ 
             $statements = [];
             foreach ($preparedStatements as $preparedStatement) {
                 $statements[] = urlencode($preparedStatement->getKey())
-                    . '=' . urlencode($preparedStatement->getValue());
+                    . '='.urlencode($preparedStatement->getValue());
             }
             $request = $request->withAddedHeader(
                 PrestoHeaders::PRESTO_PREPARED_STATEMENT,
@@ -151,7 +151,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);
@@ -211,9 +211,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();