@@ -40,13 +40,13 @@ discard block |
||
40 | 40 | |
41 | 41 | private function initListeners() |
42 | 42 | { |
43 | - $this->stream->on('data', function ($data) { |
|
43 | + $this->stream->on('data', function($data) { |
|
44 | 44 | $this->processData($data); |
45 | 45 | }); |
46 | 46 | $this->stream->once('end', function() { |
47 | 47 | $this->getHandler()->onDisconnect($this); |
48 | 48 | }); |
49 | - $this->stream->on('error', function ($data) { |
|
49 | + $this->stream->on('error', function($data) { |
|
50 | 50 | $this->error($data); |
51 | 51 | }); |
52 | 52 | } |
@@ -88,7 +88,7 @@ discard block |
||
88 | 88 | $this->currentMessage = $message; |
89 | 89 | if ($this->currentMessage->isComplete()) { |
90 | 90 | // Sending the message through the woketo API. |
91 | - switch($this->currentMessage->getOpcode()) { |
|
91 | + switch ($this->currentMessage->getOpcode()) { |
|
92 | 92 | case Frame::OP_TEXT: |
93 | 93 | $this->getHandler()->onMessage($this->currentMessage->getContent(), $this); |
94 | 94 | break; |
@@ -100,7 +100,7 @@ discard block |
||
100 | 100 | |
101 | 101 | } else { |
102 | 102 | // We wait for more data so we start a timeout. |
103 | - $this->timeout = $this->loop->addTimer(Connection::DEFAULT_TIMEOUT, function () { |
|
103 | + $this->timeout = $this->loop->addTimer(Connection::DEFAULT_TIMEOUT, function() { |
|
104 | 104 | $this->logger->notice('Connection to ' . $this->getIp() . ' timed out.'); |
105 | 105 | $this->messageProcessor->timeout($this->stream); |
106 | 106 | }); |
@@ -102,7 +102,7 @@ discard block |
||
102 | 102 | $this->buildMessageProcessor(); |
103 | 103 | |
104 | 104 | // Some optimization |
105 | - \gc_enable(); // As the process never stops, the garbage collector will be usefull, you may need to call it manually sometimes for performance purpose |
|
105 | + \gc_enable(); // As the process never stops, the garbage collector will be usefull, you may need to call it manually sometimes for performance purpose |
|
106 | 106 | \set_time_limit(0); // It's by default on most server for cli apps but better be sure of that fact |
107 | 107 | } |
108 | 108 | |
@@ -112,13 +112,13 @@ discard block |
||
112 | 112 | */ |
113 | 113 | public function setMessageHandler($messageHandler, $uri = '*') |
114 | 114 | { |
115 | - if (!$messageHandler instanceof MessageHandlerInterface && !\is_string($messageHandler)) { |
|
115 | + if (!$messageHandler instanceof MessageHandlerInterface && !\is_string($messageHandler)) { |
|
116 | 116 | throw new \InvalidArgumentException('The message handler must be an instance of MessageHandlerInterface or a string.'); |
117 | 117 | } |
118 | 118 | if (\is_string($messageHandler)) { |
119 | 119 | try { |
120 | 120 | $reflection = new \ReflectionClass($messageHandler); |
121 | - if(!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) { |
|
121 | + if (!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) { |
|
122 | 122 | throw new \InvalidArgumentException('The messageHandler must implement MessageHandlerInterface'); |
123 | 123 | } |
124 | 124 | } catch (\ReflectionException $e) { |
@@ -150,7 +150,7 @@ discard block |
||
150 | 150 | $this->getLogger()->info('Enabled ssl'); |
151 | 151 | } |
152 | 152 | |
153 | - $this->server->on('connection', function (ConnectionInterface $socketStream) { |
|
153 | + $this->server->on('connection', function(ConnectionInterface $socketStream) { |
|
154 | 154 | $this->onNewConnection($socketStream); |
155 | 155 | }); |
156 | 156 | |
@@ -164,11 +164,11 @@ discard block |
||
164 | 164 | */ |
165 | 165 | private function onNewConnection(ConnectionInterface $socketStream) |
166 | 166 | { |
167 | - $connection = new Connection($socketStream, function ($uri, Connection $connection) { |
|
167 | + $connection = new Connection($socketStream, function($uri, Connection $connection) { |
|
168 | 168 | return $this->getMessageHandler($uri, $connection); |
169 | 169 | }, $this->loop, $this->messageProcessor); |
170 | 170 | |
171 | - $socketStream->on('end', function () use($connection) { |
|
171 | + $socketStream->on('end', function() use($connection) { |
|
172 | 172 | $this->onDisconnect($connection); |
173 | 173 | }); |
174 | 174 |