Nekland / Woketo

src/Server/WebSocketServer.php

Spacing +6 added lines, -6 removed lines

@@ -98,7 +98,7 @@ 
         $this->buildMessageProcessor();
 
         // Some optimization
-        \gc_enable();       // As the process never stops, the garbage collector will be usefull, you may need to call it manually sometimes for performance purpose
+        \gc_enable(); // As the process never stops, the garbage collector will be usefull, you may need to call it manually sometimes for performance purpose
         \set_time_limit(0); // It's by default on most server for cli apps but better be sure of that fact
     }
 
@@ -108,13 +108,13 @@ 
      */
     public function setMessageHandler($messageHandler, $uri = '*')
     {
-        if (!$messageHandler instanceof MessageHandlerInterface &&  !\is_string($messageHandler)) {
+        if (!$messageHandler instanceof MessageHandlerInterface && !\is_string($messageHandler)) {
             throw new \InvalidArgumentException('The message handler must be an instance of MessageHandlerInterface or a string.');
         }
         if (\is_string($messageHandler)) {
             try {
                 $reflection = new \ReflectionClass($messageHandler);
-                if(!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) {
+                if (!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) {
                     throw new \InvalidArgumentException('The messageHandler must implement MessageHandlerInterface');
                 }
             } catch (\ReflectionException $e) {
@@ -146,7 +146,7 @@ 
             $this->getLogger()->info('Enabled ssl');
         }
 
-        $this->server->on('connection', function ($socketStream) {
+        $this->server->on('connection', function($socketStream) {
             $this->onNewConnection($socketStream);
         });
 
@@ -160,11 +160,11 @@ 
      */
     private function onNewConnection(ConnectionInterface $socketStream)
     {
-        $connection = new Connection($socketStream, function ($uri, Connection $connection) {
+        $connection = new Connection($socketStream, function($uri, Connection $connection) {
             return $this->getMessageHandler($uri, $connection);
         }, $this->loop, $this->messageProcessor);
 
-        $socketStream->on('end', function () use($connection) {
+        $socketStream->on('end', function() use($connection) {
             $this->onDisconnect($connection);
         });
 

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