Nekland / Woketo

src/Server/WebSocketServer.php

Spacing +4 added lines, -4 removed lines

@@ -83,19 +83,19 @@ 
         $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
     }
 
     public function setMessageHandler($messageHandler)
     {
-        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) {
@@ -114,7 +114,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);