pheanstalk / pheanstalk

src/Command/PeekJobCommand.php

Spacing +1 added lines, -1 removed lines

@@ -56,6 +56,6 @@
             );
         }
 
-        throw new Exception\ServerException("Unexpected response: " . $responseLine);
+        throw new Exception\ServerException("Unexpected response: ".$responseLine);
     }
 }

src/Command/WatchCommand.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
 {
     public function getCommandLine(): string
     {
-        return 'watch ' . $this->tube;
+        return 'watch '.$this->tube;
     }
 
     public function parseResponse(string $responseLine, ?string $responseData): ArrayResponse

src/Command/PauseTubeCommand.php

Spacing +1 added lines, -1 removed lines

@@ -49,7 +49,7 @@
         } elseif ($responseLine == ResponseInterface::RESPONSE_PAUSED) {
             return $this->createResponse(ResponseInterface::RESPONSE_PAUSED);
         } else {
-            throw new Exception('Unhandled response: "' . $responseLine . '"');
+            throw new Exception('Unhandled response: "'.$responseLine.'"');
         }
     }
 }

src/Command/KickCommand.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
 
     public function getCommandLine(): string
     {
-        return 'kick ' . $this->max;
+        return 'kick '.$this->max;
     }
 
     /* (non-phpdoc)

src/Command/KickJobCommand.php

Spacing +2 added lines, -2 removed lines

@@ -23,7 +23,7 @@ 
 {
     public function getCommandLine(): string
     {
-        return 'kick-job ' . $this->jobId;
+        return 'kick-job '.$this->jobId;
     }
 
     /* (non-phpdoc)
@@ -40,7 +40,7 @@ 
         } elseif ($responseLine == ResponseInterface::RESPONSE_KICKED) {
             return $this->createResponse(ResponseInterface::RESPONSE_KICKED);
         } else {
-            throw new Exception('Unhandled response: ' . $responseLine);
+            throw new Exception('Unhandled response: '.$responseLine);
         }
     }
 }

src/Command/DeleteCommand.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 {
     public function getCommandLine(): string
     {
-        return 'delete ' . $this->jobId;
+        return 'delete '.$this->jobId;
     }
 
     public function parseResponse(string $responseLine, ?string $responseData): ArrayResponse

src/Pheanstalk.php

Spacing +2 added lines, -2 removed lines

@@ -108,7 +108,7 @@ 
      */
     public function listTubes(): array
     {
-        return (array)$this->dispatch(
+        return (array) $this->dispatch(
             new Command\ListTubesCommand()
         );
     }
@@ -119,7 +119,7 @@ 
     public function listTubesWatched(bool $askServer = false): array
     {
         if ($askServer) {
-            $response = (array)$this->dispatch(
+            $response = (array) $this->dispatch(
                 new Command\ListTubesWatchedCommand()
             );
             $this->watching = array_fill_keys($response, true);

src/YamlResponseParser.php

Spacing +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
             ));
         }
 
-        $lines = array_filter(explode("\n", $responseData), function ($line) {
+        $lines = array_filter(explode("\n", $responseData), function($line) {
             return !empty($line) && $line !== '---';
         });
 
@@ -63,7 +63,7 @@ 
         $data = [];
         foreach ($lines as $line) {
             if (strncmp($line, '- ', 2) !== 0) {
-                throw new ClientException("YAML parse error for line: $line" . print_r($lines, true));
+                throw new ClientException("YAML parse error for line: $line".print_r($lines, true));
             }
             $data[] = substr($line, 2);
         }

src/Connection.php

Spacing +2 added lines, -2 removed lines

@@ -73,10 +73,10 @@
     {
         $socket = $this->getSocket();
 
-        $to_send = $command->getCommandLine() . self::CRLF;
+        $to_send = $command->getCommandLine().self::CRLF;
 
         if ($command->hasData()) {
-            $to_send .= $command->getData() . self::CRLF;
+            $to_send .= $command->getData().self::CRLF;
         }
 
         $socket->write($to_send);