Nekland / Woketo

src/Core/AbstractConnection.php

Unused Use Statements +13 added lines, -13 removed lines

@@ -11,19 +11,19 @@
 

 namespace Nekland\Woketo\Core;

 

-use Nekland\Woketo\Exception\NoHandlerException;

-use Nekland\Woketo\Exception\WebsocketException;

-use Nekland\Woketo\Message\MessageHandlerInterface;

-use Nekland\Woketo\Rfc6455\Frame;

-use Nekland\Woketo\Rfc6455\Handshake\HandshakeInterface;

-use Nekland\Woketo\Rfc6455\Message;

-use Nekland\Woketo\Rfc6455\MessageProcessor;

-use Nekland\Woketo\Utils\SimpleLogger;

-use Psr\Log\LoggerAwareTrait;

-use Psr\Log\LoggerInterface;

-use React\EventLoop\LoopInterface;

-use React\EventLoop\TimerInterface;

-use React\Socket\Connection;

+use Nekland\Woketo\Exception\NoHandlerException;
+use Nekland\Woketo\Exception\WebsocketException;
+use Nekland\Woketo\Message\MessageHandlerInterface;
+use Nekland\Woketo\Rfc6455\Frame;
+use Nekland\Woketo\Rfc6455\Handshake\HandshakeInterface;
+use Nekland\Woketo\Rfc6455\Message;
+use Nekland\Woketo\Rfc6455\MessageProcessor;
+use Nekland\Woketo\Utils\SimpleLogger;
+use Psr\Log\LoggerAwareTrait;
+use Psr\Log\LoggerInterface;
+use React\EventLoop\LoopInterface;
+use React\EventLoop\TimerInterface;
+use React\Socket\Connection;
 use React\Socket\ConnectionInterface;

 

 abstract class AbstractConnection

src/Rfc6455/Message.php

Doc Comments +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
     /**
      * Add some data to the buffer.
      *
-     * @param $data
+     * @param string $data
      */
     public function addBuffer($data)
     {

src/Server/Connection.php

Spacing +4 added lines, -4 removed lines

@@ -40,13 +40,13 @@ 
 
     private function initListeners()
     {
-        $this->stream->on('data', function ($data) {
+        $this->stream->on('data', function($data) {
             $this->processData($data);
         });
         $this->stream->once('end', function() {
             $this->getHandler()->onDisconnect($this);
         });
-        $this->stream->on('error', function ($data) {
+        $this->stream->on('error', function($data) {
             $this->error($data);
         });
     }
@@ -88,7 +88,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->getHandler()->onMessage($this->currentMessage->getContent(), $this);
                         break;
@@ -100,7 +100,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->logger->notice('Connection to ' . $this->getIp() . ' timed out.');
                     $this->messageProcessor->timeout($this->stream);
                 });