Nekland / Woketo

src/Server/WebSocketServer.php

Spacing +6 added lines, -6 removed lines

@@ -102,7 +102,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
     }
 
@@ -112,13 +112,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) {
@@ -150,7 +150,7 @@ 
             $this->getLogger()->info('Enabled ssl');
         }
 
-        $this->server->on('connection', function (ConnectionInterface $socketStream) {
+        $this->server->on('connection', function(ConnectionInterface $socketStream) {
             $this->onNewConnection($socketStream);
         });
 
@@ -164,11 +164,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);
         });