seregazhuk / php-react-memcached

src/Protocol/Request/SimpleRequest.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
     public function __construct($command, $args)
     {
         $command = $this->camelCaseToUnderScore($command);
-        $args = empty($args) ? '' : ' ' . implode(' ' , $args);
+        $args = empty($args) ? '' : ' ' . implode(' ', $args);
         $this->command = $command . $args . Parser::COMMAND_SEPARATOR;
     }
 

src/Connection.php

Spacing +5 added lines, -5 removed lines

@@ -68,13 +68,13 @@ 
         $this->stream = $stream;
         $this->isConnecting = false;
 
-        $stream->on('data', function ($chunk) {
+        $stream->on('data', function($chunk) {
             $this->emit('data', [$chunk]);
         });
 
         $stream->on('close', [$this, 'close']);
 
-        while($this->queries) {
+        while ($this->queries) {
             $this->stream->write(array_shift($this->queries));
         }
     }
@@ -87,7 +87,7 @@ 
 
     public function close()
     {
-        if($this->stream) {
+        if ($this->stream) {
             $this->stream->close();
         }
 
@@ -100,13 +100,13 @@ 
      */
     public function write($query)
     {
-        if($this->stream && $this->stream->isWritable()) {
+        if ($this->stream && $this->stream->isWritable()) {
             $this->stream->write($query);
             return;
         }
 
         $this->queries[] = $query;
-        if(!$this->isConnecting) {
+        if (!$this->isConnecting) {
             $this->connect();
         }
     }

src/Client.php

Spacing +4 added lines, -4 removed lines

@@ -71,7 +71,7 @@ 
 
     protected function setConnectionHandlers()
     {
-        $this->connection->on('data', function ($chunk) {
+        $this->connection->on('data', function($chunk) {
             $parsed = $this->parser->parseRawResponse($chunk);
             $this->resolveRequests($parsed);
         });
@@ -80,7 +80,7 @@ 
             $this->rejectPendingRequestsWith(new ConnectionClosedException());
         });
 
-        $this->connection->on('close', function () {
+        $this->connection->on('close', function() {
             if (!$this->isEnding) {
                 $this->emit('error', [new ConnectionClosedException()]);
             }
@@ -96,7 +96,7 @@ 
     {
         $request = new Request($name);
 
-        if($this->isEnding) {
+        if ($this->isEnding) {
             $request->reject(new ConnectionClosedException());
         } else {
             try {
@@ -173,7 +173,7 @@ 
      */
     protected function rejectPendingRequestsWith(Exception $exception)
     {
-        while($this->hasPendingRequests()) {
+        while ($this->hasPendingRequests()) {
             $request = array_shift($this->requests);
             /* @var $request Request */
             $request->reject($exception);