seregazhuk / php-react-memcached

src/Protocol/Parser.php

Spacing +5 added lines, -5 removed lines

@@ -114,7 +114,7 @@ 
                 $result = '';
             }
 
-            if(strpos($line, self::RESPONSE_VERSION) !== false) {
+            if (strpos($line, self::RESPONSE_VERSION) !== false) {
                 $results[] = $line;
                 $result = '';
             }
@@ -122,7 +122,7 @@ 
             $result .= self::COMMAND_SEPARATOR;
         }
 
-        if(!empty($result) && $result !== self::COMMAND_SEPARATOR) {
+        if (!empty($result) && $result !== self::COMMAND_SEPARATOR) {
             $results[] = $result;
         }
 
@@ -158,7 +158,7 @@ 
      */
     public function createResponse($command, $data)
     {
-        switch($command) {
+        switch ($command) {
             case self::COMMAND_GET:
                 return new ReadResponse($data);
             case self::COMMAND_SET:
@@ -190,11 +190,11 @@ 
      */
     public function createRequest($command, $args)
     {
-        if(!in_array($command, self::COMMANDS)) {
+        if (!in_array($command, self::COMMANDS)) {
             throw new WrongCommandException("Unknown command: $command");
         }
 
-        if(in_array($command, self::STORAGE_COMMANDS)) {
+        if (in_array($command, self::STORAGE_COMMANDS)) {
             return new StorageRequest($command, ...$args);
         }
 

src/Protocol/Response/DeleteResponse.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function parse()
     {
-        if(trim($this->data) !== Parser::RESPONSE_DELETED) {
+        if (trim($this->data) !== Parser::RESPONSE_DELETED) {
             $this->fail();
         }
 

src/Protocol/Response/OkResponse.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
      */
     public function parse()
     {
-        if(trim($this->data) !== Parser::RESPONSE_OK) {
+        if (trim($this->data) !== Parser::RESPONSE_OK) {
             $this->fail();
         }
 

src/Protocol/Response/StatsResponse.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 
         foreach ($lines as $line) {
             preg_match('/STAT (\w+) (\w+)/', $line, $matches);
-            if(empty($matches)) {
+            if (empty($matches)) {
                 break;
             }
 

src/Protocol/Response/TouchResponse.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function parse()
     {
-        if(trim($this->data) !== Parser::RESPONSE_TOUCHED) {
+        if (trim($this->data) !== Parser::RESPONSE_TOUCHED) {
             $this->fail();
         }
 

src/Protocol/Response/ReadResponse.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 
         $value = isset($match[1]) ? trim($match[1]) : null;
 
-        if(null === $value) {
+        if (null === $value) {
             $this->fail();
         }
 

src/Protocol/Response/ValueResponse.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function parse()
     {
-        if($this->data === Parser::RESPONSE_NOT_FOUND) {
+        if ($this->data === Parser::RESPONSE_NOT_FOUND) {
             $this->fail();
         }
 

src/Protocol/Response/WriteResponse.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
      */
     public function parse()
     {
-        if(trim($this->data) !== Parser::RESPONSE_STORED) {
+        if (trim($this->data) !== Parser::RESPONSE_STORED) {
             $this->fail();
         }
 

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();
         }
     }