Nekland / Woketo

src/Client/Connection.php

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

@@ -12,18 +12,18 @@
 namespace Nekland\Woketo\Client;

 

 

-use Nekland\Woketo\Core\AbstractConnection;

-use Nekland\Woketo\Exception\Http\IncompleteHttpMessageException;

-use Nekland\Woketo\Exception\RuntimeException;

-use Nekland\Woketo\Exception\WebsocketException;

-use Nekland\Woketo\Http\Response;

-use Nekland\Woketo\Http\Url;

-use Nekland\Woketo\Message\MessageHandlerInterface;

-use Nekland\Woketo\Rfc6455\Frame;

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

-use Nekland\Woketo\Rfc6455\MessageProcessor;

-use React\EventLoop\LoopInterface;

-use React\Promise\PromiseInterface;

+use Nekland\Woketo\Core\AbstractConnection;
+use Nekland\Woketo\Exception\Http\IncompleteHttpMessageException;
+use Nekland\Woketo\Exception\RuntimeException;
+use Nekland\Woketo\Exception\WebsocketException;
+use Nekland\Woketo\Http\Response;
+use Nekland\Woketo\Http\Url;
+use Nekland\Woketo\Message\MessageHandlerInterface;
+use Nekland\Woketo\Rfc6455\Frame;
+use Nekland\Woketo\Rfc6455\Handshake\ClientHandshake;
+use Nekland\Woketo\Rfc6455\MessageProcessor;
+use React\EventLoop\LoopInterface;
+use React\Promise\PromiseInterface;
 use React\Socket\ConnectionInterface;

 

 class Connection extends AbstractConnection

Spacing +5 added lines, -5 removed lines

@@ -52,17 +52,17 @@ 
         $this->buffer = '';

         $this->handler = $handler;

 

-        $clientPromise->then(function (ConnectionInterface $stream) {

+        $clientPromise->then(function(ConnectionInterface $stream) {

             $this->stream = $stream;

             $this->onConnection($stream);

-        }, function (\Exception $error) {

+        }, function(\Exception $error) {

             $this->onError($error);

         });

     }

 

     private function onConnection(ConnectionInterface $stream)

     {

-        $stream->on('data', function (string $data) {

+        $stream->on('data', function(string $data) {

             $this->onMessage($data);

         });

 

@@ -123,7 +123,7 @@ 
 

             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;

@@ -135,7 +135,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->getLogger()->notice('Connection to ' . $this->getIp() . ' timed out.');

                     $this->messageProcessor->timeout($this->stream);

                 });

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\Timer\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\Timer\TimerInterface;
+use React\Socket\Connection;
 use React\Socket\ConnectionInterface;

 

 abstract class AbstractConnection