@@ -102,13 +102,13 @@ discard block |
||
| 102 | 102 | |
| 103 | 103 | public function setMessageHandler($messageHandler) |
| 104 | 104 | { |
| 105 | - if (!$messageHandler instanceof MessageHandlerInterface && !is_string($messageHandler)) { |
|
| 105 | + if (!$messageHandler instanceof MessageHandlerInterface && !is_string($messageHandler)) { |
|
| 106 | 106 | throw new \InvalidArgumentException('The message handler must be an instance of MessageHandlerInterface or a string.'); |
| 107 | 107 | } |
| 108 | 108 | if (is_string($messageHandler)) { |
| 109 | 109 | try { |
| 110 | 110 | $reflection = new \ReflectionClass($messageHandler); |
| 111 | - if(!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) { |
|
| 111 | + if (!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) { |
|
| 112 | 112 | throw new \InvalidArgumentException('The messageHandler must implement MessageHandlerInterface'); |
| 113 | 113 | } |
| 114 | 114 | } catch (\ReflectionException $e) { |
@@ -124,7 +124,7 @@ discard block |
||
| 124 | 124 | $this->loop = \React\EventLoop\Factory::create(); |
| 125 | 125 | |
| 126 | 126 | $socket = new \React\Socket\Server($this->loop); |
| 127 | - $socket->on('connection', function ($socketStream) { |
|
| 127 | + $socket->on('connection', function($socketStream) { |
|
| 128 | 128 | $this->onNewConnection($socketStream); |
| 129 | 129 | }); |
| 130 | 130 | $socket->listen($this->port); |
@@ -8,7 +8,7 @@ discard block |
||
| 8 | 8 | * on the root directory of this project |
| 9 | 9 | */ |
| 10 | 10 | |
| 11 | -declare(strict_types=1); |
|
| 11 | +declare(strict_types = 1); |
|
| 12 | 12 | namespace Nekland\Woketo\Rfc6455; |
| 13 | 13 | |
| 14 | 14 | use Nekland\Woketo\Exception\Frame\ControlFrameException; |
@@ -26,11 +26,11 @@ discard block |
||
| 26 | 26 | */ |
| 27 | 27 | class Frame |
| 28 | 28 | { |
| 29 | - const OP_CONTINUE = 0; |
|
| 30 | - const OP_TEXT = 1; |
|
| 31 | - const OP_BINARY = 2; |
|
| 32 | - const OP_CLOSE = 8; |
|
| 33 | - const OP_PING = 9; |
|
| 29 | + const OP_CONTINUE = 0; |
|
| 30 | + const OP_TEXT = 1; |
|
| 31 | + const OP_BINARY = 2; |
|
| 32 | + const OP_CLOSE = 8; |
|
| 33 | + const OP_PING = 9; |
|
| 34 | 34 | const OP_PONG = 10; |
| 35 | 35 | |
| 36 | 36 | // To understand codes, please refer to RFC: |
@@ -586,7 +586,7 @@ discard block |
||
| 586 | 586 | { |
| 587 | 587 | $this->config = array_merge([ |
| 588 | 588 | 'maxPayloadSize' => Frame::$defaultMaxPayloadSize, |
| 589 | - ],$config); |
|
| 589 | + ], $config); |
|
| 590 | 590 | |
| 591 | 591 | return $this; |
| 592 | 592 | } |