Nekland / Woketo

src/Server/WebSocketServer.php

Spacing +5 added lines, -5 removed lines

@@ -89,7 +89,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
     }
 
@@ -99,13 +99,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) {
@@ -124,7 +124,7 @@ 
         $this->loop = \React\EventLoop\Factory::create();
 
         $socket = new \React\Socket\Server($this->loop);
-        $socket->on('connection', function ($socketStream) {
+        $socket->on('connection', function($socketStream) {
             $this->onNewConnection($socketStream);
         });
         $socket->listen($this->port);
@@ -139,7 +139,7 @@ 
      */
     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);