Nekland / Woketo

src/Rfc6455/Frame.php

Doc Comments +3 added lines

@@ -130,6 +130,9 @@
      */
     private $infoBytesLen;
 
+    /**
+     * @param string $data
+     */
     public function __construct($data=null)
     {
         if (null !== $data) {

Spacing +7 added lines, -7 removed lines

@@ -8,7 +8,7 @@ 
  * on the root directory of this project
  */
 
-declare(strict_types=1);
+declare(strict_types = 1);
 namespace Nekland\Woketo\Rfc6455;
 
 use Nekland\Woketo\Exception\Frame\ControlFrameException;
@@ -25,11 +25,11 @@ 
  */
 class Frame
 {
-    const OP_CONTINUE =  0;
-    const OP_TEXT     =  1;
-    const OP_BINARY   =  2;
-    const OP_CLOSE    =  8;
-    const OP_PING     =  9;
+    const OP_CONTINUE = 0;
+    const OP_TEXT     = 1;
+    const OP_BINARY   = 2;
+    const OP_CLOSE    = 8;
+    const OP_PING     = 9;
     const OP_PONG     = 10;
 
     // To understand codes, please refer to RFC:
@@ -130,7 +130,7 @@ 
      */
     private $infoBytesLen;
 
-    public function __construct($data=null)
+    public function __construct($data = null)
     {
         if (null !== $data) {
             $this->setRawData($data);

src/Server/Connection.php

Spacing +3 added lines, -3 removed lines

@@ -83,7 +83,7 @@ 
 
     private function initListeners()
     {
-        $this->socketStream->on('data', function ($data) {
+        $this->socketStream->on('data', function($data) {
             $this->processData($data);
         });
         $this->socketStream->on('error', [$this, 'error']);
@@ -124,7 +124,7 @@ 
             $this->currentMessage = $message;
             if ($this->currentMessage->isComplete()) {
                 // Sending the message through the woketo API.
-                switch($this->currentMessage->getOpcode()) {
+                switch ($this->currentMessage->getOpcode()) {
                     case Frame::OP_TEXT:
                         $this->handler->onMessage($this->currentMessage->getContent(), $this);
                         break;
@@ -136,7 +136,7 @@ 
 
             } else {
                 // We wait for more data so we start a timeout.
-                $this->timeout = $this->loop->addTimer(Connection::DEFAULT_TIMEOUT, function () {
+                $this->timeout = $this->loop->addTimer(Connection::DEFAULT_TIMEOUT, function() {
                     $this->messageProcessor->timeout($this->socketStream);
                 });
             }

src/Rfc6455/Message.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
             } catch (IncompleteFrameException $e) {
                 return ''; // There is no more frame we can generate, the data is saved as buffer.
             }
-        } while(!$this->isComplete() && !empty($this->buffer));
+        } while (!$this->isComplete() && !empty($this->buffer));
 
         if ($this->isComplete()) {
             return $this->buffer;

src/Rfc6455/MessageProcessor.php

Spacing +1 added lines, -1 removed lines

@@ -81,7 +81,7 @@
                 $socket->end();
                 $data = '';
             }
-        } while(!empty($data));
+        } while (!empty($data));
 
         return $messages;
     }