Nekland / Woketo

src/Client/Connection.php

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

                 });