hfw / socket

src/AbstractSocket.php

Spacing +29 added lines, -29 removed lines

@@ -14,7 +14,7 @@ 
      *
      * @return int
      */
-    abstract public static function getType (): int;
+    abstract public static function getType(): int;
 
     /**
      * The underlying PHP resource.
@@ -33,7 +33,7 @@ 
      * @return static
      * @throws SocketError
      */
-    public static function create (int $domain = AF_INET, ...$extra) {
+    public static function create(int $domain = AF_INET, ...$extra) {
         if (!$resource = @socket_create($domain, static::getType(), 0)) { // auto-protocol
             throw new SocketError; // reliable errno
         }
@@ -49,12 +49,12 @@ 
      * @throws InvalidArgumentException Not a socket resource, or the socket is of the wrong type.
      * @throws SocketError Slippage of an existing error on the resource.
      */
-    public function __construct ($resource) {
+    public function __construct($resource) {
         if (!is_resource($resource) or get_resource_type($resource) !== 'Socket') {
             throw new InvalidArgumentException('Expected an open socket resource.', SOCKET_EBADF);
         }
         elseif (socket_get_option($resource, SOL_SOCKET, SO_TYPE) !== static::getType()) {
-            throw new InvalidArgumentException('Invalid socket type for ' . static::class, SOCKET_ESOCKTNOSUPPORT);
+            throw new InvalidArgumentException('Invalid socket type for '.static::class, SOCKET_ESOCKTNOSUPPORT);
         }
         elseif ($errno = SocketError::getLast($resource)) {
             // "File descriptor in bad state"
@@ -68,7 +68,7 @@ 
      *
      * @see close()
      */
-    public function __destruct () {
+    public function __destruct() {
         if ($this->isOpen()) {
             $this->close();
         }
@@ -85,7 +85,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function await (int $channel) {
+    public function await(int $channel) {
         $rwe = [$channel => [$this->resource]];
         if (!@socket_select($rwe[0], $rwe[1], $rwe[2], null)) {
             throw new SocketError($this->resource);
@@ -98,7 +98,7 @@ 
      *
      * @return $this
      */
-    final public function awaitOutOfBand () {
+    final public function awaitOutOfBand() {
         return $this->await(self::CH_EXCEPT);
     }
 
@@ -107,7 +107,7 @@ 
      *
      * @return $this
      */
-    final public function awaitReadable () {
+    final public function awaitReadable() {
         return $this->await(self::CH_READ);
     }
 
@@ -116,7 +116,7 @@ 
      *
      * @return $this
      */
-    final public function awaitWritable () {
+    final public function awaitWritable() {
         return $this->await(self::CH_WRITE);
     }
 
@@ -129,7 +129,7 @@ 
      *
      * @return $this
      */
-    public function close () {
+    public function close() {
         socket_close($this->resource);
         return $this;
     }
@@ -139,15 +139,15 @@ 
      *
      * @return int
      */
-    final public function getDomain (): int {
+    final public function getDomain(): int {
         return $this->getOption(39); // SO_DOMAIN is not exposed by PHP
     }
 
     /**
      * @return int
      */
-    final public function getId (): int {
-        return (int)$this->resource;
+    final public function getId(): int {
+        return (int) $this->resource;
     }
 
     /**
@@ -159,7 +159,7 @@ 
      * @return mixed The option's value. This is never `false`.
      * @throws SocketError
      */
-    public function getOption (int $option) {
+    public function getOption(int $option) {
         $value = @socket_get_option($this->resource, SOL_SOCKET, $option);
         if ($value === false) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
@@ -170,7 +170,7 @@ 
     /**
      * @return resource
      */
-    final public function getResource () {
+    final public function getResource() {
         return $this->resource;
     }
 
@@ -182,7 +182,7 @@ 
      * @return array `[ 0 => address, 1 => port ]`
      * @throws SocketError
      */
-    public function getSockName (): array {
+    public function getSockName(): array {
         if (!@socket_getsockname($this->resource, $addr, $port)) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);
         }
@@ -192,7 +192,7 @@ 
     /**
      * @return bool
      */
-    public function isOpen (): bool {
+    public function isOpen(): bool {
         return is_resource($this->resource);
     }
 
@@ -203,7 +203,7 @@ 
      *
      * @return bool
      */
-    final public function isOutOfBand (): bool {
+    final public function isOutOfBand(): bool {
         return $this->isReady(self::CH_EXCEPT);
     }
 
@@ -214,7 +214,7 @@ 
      *
      * @return bool
      */
-    final public function isReadable (): bool {
+    final public function isReadable(): bool {
         return $this->isReady(self::CH_READ);
     }
 
@@ -228,15 +228,15 @@ 
      * @return bool
      * @throws SocketError
      */
-    public function isReady (int $channel, ?float $timeout = 0): bool {
+    public function isReady(int $channel, ?float $timeout = 0): bool {
         $rwe = [$channel => [$this->resource]];
         // core casts non-null timeout to int.
         // usec is ignored if timeout is null.
-        $usec = (int)(fmod($timeout, 1) * 1000000);
+        $usec = (int) (fmod($timeout, 1) * 1000000);
         if (false === $count = @socket_select($rwe[0], $rwe[1], $rwe[2], $timeout, $usec)) {
             throw new SocketError($this->resource);
         }
-        return (bool)$count;
+        return (bool) $count;
     }
 
     /**
@@ -246,7 +246,7 @@ 
      *
      * @return bool
      */
-    final public function isWritable (): bool {
+    final public function isWritable(): bool {
         return $this->isReady(self::CH_WRITE);
     }
 
@@ -270,7 +270,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function setBlocking (bool $blocking) {
+    public function setBlocking(bool $blocking) {
         if ($blocking ? @socket_set_block($this->resource) : @socket_set_nonblock($this->resource)) {
             return $this;
         }
@@ -287,7 +287,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function setOption (int $option, $value) {
+    public function setOption(int $option, $value) {
         if (!@socket_set_option($this->resource, SOL_SOCKET, $option, $value)) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
         }
@@ -300,10 +300,10 @@ 
      * @param float $timeout Zero means "no timeout" (block forever).
      * @return $this
      */
-    public function setTimeout (float $timeout) {
+    public function setTimeout(float $timeout) {
         $tv = [
-            'sec' => (int)$timeout,
-            'usec' => (int)(fmod($timeout, 1) * 1000000)
+            'sec' => (int) $timeout,
+            'usec' => (int) (fmod($timeout, 1) * 1000000)
         ];
         $this->setOption(SO_RCVTIMEO, $tv);
         $this->setOption(SO_SNDTIMEO, $tv);
@@ -333,7 +333,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function shutdown (int $channel) {
+    public function shutdown(int $channel) {
         if (!@socket_shutdown($this->resource, $channel)) {
             throw new SocketError($this->resource); // reliable errno
         }

src/WebSocket/WebSocketClient.php

Spacing +17 added lines, -17 removed lines

@@ -57,7 +57,7 @@ 
      * @param resource $resource
      * @param WebSocketServer $server
      */
-    public function __construct ($resource, WebSocketServer $server) {
+    public function __construct($resource, WebSocketServer $server) {
         parent::__construct($resource);
         $this->server = $server;
         $this->handshake = new HandShake($this);
@@ -83,7 +83,7 @@ 
      * @param string $reason Sent to the peer, if code is >= 1000
      * @return $this
      */
-    public function close (int $code = null, string $reason = '') {
+    public function close(int $code = null, string $reason = '') {
         try {
             if ($code >= 1000 and $this->isOk()) {
                 $this->frameHandler->writeClose($code, $reason);
@@ -100,35 +100,35 @@ 
     /**
      * @return FrameHandler
      */
-    public function getFrameHandler (): FrameHandler {
+    public function getFrameHandler(): FrameHandler {
         return $this->frameHandler;
     }
 
     /**
      * @return HandShake
      */
-    public function getHandshake (): HandShake {
+    public function getHandshake(): HandShake {
         return $this->handshake;
     }
 
     /**
      * @return WebSocketServer
      */
-    public function getServer (): WebSocketServer {
+    public function getServer(): WebSocketServer {
         return $this->server;
     }
 
     /**
      * @return int
      */
-    public function getState (): int {
+    public function getState(): int {
         return $this->state;
     }
 
     /**
      * @return bool
      */
-    final public function isOk (): bool {
+    final public function isOk(): bool {
         return $this->state === self::STATE_OK;
     }
 
@@ -140,7 +140,7 @@ 
      * @param string $binary
      * @throws WebSocketError
      */
-    public function onBinary (string $binary): void {
+    public function onBinary(string $binary): void {
         unset($binary);
         throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle binary data.");
     }
@@ -151,7 +151,7 @@ 
      * @param int $code
      * @param string $reason
      */
-    public function onClose (int $code, string $reason): void {
+    public function onClose(int $code, string $reason): void {
         unset($code, $reason);
         $this->close();
     }
@@ -163,7 +163,7 @@ 
      *
      * Closes the connection with a protocol-error frame.
      */
-    final public function onOutOfBand (): void {
+    final public function onOutOfBand(): void {
         $this->close(Frame::CLOSE_PROTOCOL_ERROR, "Received out-of-band data.");
     }
 
@@ -174,7 +174,7 @@ 
      *
      * @param string $message
      */
-    public function onPing (string $message): void {
+    public function onPing(string $message): void {
         $this->frameHandler->writePong($message);
     }
 
@@ -185,7 +185,7 @@ 
      *
      * @param string $message
      */
-    public function onPong (string $message): void {
+    public function onPong(string $message): void {
         // stub
     }
 
@@ -195,7 +195,7 @@ 
      * @throws WebSocketError
      * @throws Throwable
      */
-    public function onReadable (): void {
+    public function onReadable(): void {
         if (!strlen($this->recv(1, MSG_PEEK))) { // peer has shut down writing, or closed.
             $this->close();
             return;
@@ -232,7 +232,7 @@ 
      *
      * Does nothing by default.
      */
-    protected function onStateOk (): void {
+    protected function onStateOk(): void {
         // stub
     }
 
@@ -244,7 +244,7 @@ 
      * @param string $text
      * @throws WebSocketError
      */
-    public function onText (string $text): void {
+    public function onText(string $text): void {
         unset($text);
         throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle text.");
     }
@@ -254,7 +254,7 @@ 
      *
      * @param string $binary
      */
-    public function writeBinary (string $binary): void {
+    public function writeBinary(string $binary): void {
         $this->frameHandler->writeBinary($binary);
     }
 
@@ -263,7 +263,7 @@ 
      *
      * @param string $text
      */
-    public function writeText (string $text): void {
+    public function writeText(string $text): void {
         $this->frameHandler->writeText($text);
     }
 

Braces +3 added lines, -6 removed lines

@@ -88,8 +88,7 @@ 
             if ($code >= 1000 and $this->isOk()) {
                 $this->frameHandler->writeClose($code, $reason);
             }
-        }
-        finally {
+        } finally {
             $this->server->remove($this);
             parent::close();
             $this->state = self::STATE_CLOSED;
@@ -216,12 +215,10 @@ 
                 case self::STATE_CLOSED:
                     return;
             }
-        }
-        catch (WebSocketError $e) {
+        } catch (WebSocketError $e) {
             $this->close($e->getCode(), $e->getMessage());
             throw $e;
-        }
-        catch (Throwable $e) {
+        } catch (Throwable $e) {
             $this->close(Frame::CLOSE_INTERNAL_ERROR);
             throw $e;
         }

src/WebSocket/FrameHandler.php

Spacing +27 added lines, -27 removed lines

@@ -51,21 +51,21 @@ 
     /**
      * @param WebSocketClient $client
      */
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @return int
      */
-    public function getFragmentSize (): int {
+    public function getFragmentSize(): int {
         return $this->fragmentSize;
     }
 
     /**
      * @return int
      */
-    public function getMaxLength (): int {
+    public function getMaxLength(): int {
         return $this->maxLength;
     }
 
@@ -76,7 +76,7 @@ 
      * @param Frame $frame
      * @throws WebSocketError
      */
-    protected function onBinary (Frame $frame): void {
+    protected function onBinary(Frame $frame): void {
         $this->buffer .= $frame->getPayload();
         if ($frame->isFinal()) {
             $binary = $this->buffer;
@@ -96,7 +96,7 @@ 
      *
      * @param Frame $frame
      */
-    protected function onClose (Frame $frame): void {
+    protected function onClose(Frame $frame): void {
         $this->client->onClose($frame->getCloseCode(), $frame->getCloseReason());
     }
 
@@ -106,7 +106,7 @@ 
      * @param Frame $frame
      * @throws WebSocketError
      */
-    protected function onContinue (Frame $frame): void {
+    protected function onContinue(Frame $frame): void {
         if (!$this->continue) {
             throw new WebSocketError(
                 Frame::CLOSE_PROTOCOL_ERROR,
@@ -138,7 +138,7 @@ 
      *
      * @param Frame $frame
      */
-    protected function onControl (Frame $frame): void {
+    protected function onControl(Frame $frame): void {
         if ($frame->isClose()) {
             $this->onClose($frame);
         }
@@ -158,7 +158,7 @@ 
      *
      * @param Frame $frame
      */
-    protected function onData (Frame $frame): void {
+    protected function onData(Frame $frame): void {
         $this->onData_SetContinue($frame);
         if ($frame->isText()) {
             $this->onText($frame);
@@ -174,11 +174,11 @@ 
      * @param Frame $frame
      * @throws WebSocketError
      */
-    protected function onData_SetContinue (Frame $frame): void {
+    protected function onData_SetContinue(Frame $frame): void {
         if ($this->continue) {
             throw new WebSocketError(
                 Frame::CLOSE_PROTOCOL_ERROR,
-                "Received interleaved {$frame->getName()} against existing " . Frame::NAMES[$this->continue],
+                "Received interleaved {$frame->getName()} against existing ".Frame::NAMES[$this->continue],
                 $frame
             );
         }
@@ -196,7 +196,7 @@ 
      *
      * @param Frame $frame
      */
-    public function onFrame (Frame $frame): void {
+    public function onFrame(Frame $frame): void {
         $this->onFrame_CheckRsv($frame);
         $this->onFrame_CheckLength($frame);
         if ($frame->isControl()) {
@@ -216,7 +216,7 @@ 
      * @param Frame $frame
      * @throws WebSocketError
      */
-    protected function onFrame_CheckLength (Frame $frame): void {
+    protected function onFrame_CheckLength(Frame $frame): void {
         if ($frame->isData()) {
             $length = strlen($this->buffer);
             if ($length + $frame->getLength() > $this->maxLength) {
@@ -235,7 +235,7 @@ 
      * @param Frame $frame
      * @throws WebSocketError
      */
-    protected function onFrame_CheckRsv (Frame $frame): void {
+    protected function onFrame_CheckRsv(Frame $frame): void {
         if ($badRsv = $frame->getRsv() & ~$this->client->getHandshake()->getRsv()) {
             $badRsv = str_pad(base_convert($badRsv >> 4, 10, 2), 3, '0', STR_PAD_LEFT);
             throw new WebSocketError(
@@ -251,7 +251,7 @@ 
      *
      * @param Frame $frame
      */
-    protected function onPing (Frame $frame): void {
+    protected function onPing(Frame $frame): void {
         $this->client->onPing($frame->getPayload());
     }
 
@@ -260,7 +260,7 @@ 
      *
      * @param Frame $frame
      */
-    protected function onPong (Frame $frame): void {
+    protected function onPong(Frame $frame): void {
         $this->client->onPong($frame->getPayload());
     }
 
@@ -271,7 +271,7 @@ 
      * @param Frame $frame
      * @throws WebSocketError
      */
-    protected function onText (Frame $frame): void {
+    protected function onText(Frame $frame): void {
         $this->buffer .= $frame->getPayload();
         if ($frame->isFinal()) {
             if (!mb_detect_encoding($this->buffer, 'UTF-8', true)) {
@@ -287,7 +287,7 @@ 
      * @param int $bytes
      * @return $this
      */
-    public function setFragmentSize (int $bytes) {
+    public function setFragmentSize(int $bytes) {
         $this->fragmentSize = $bytes;
         return $this;
     }
@@ -296,7 +296,7 @@ 
      * @param int $bytes
      * @return $this
      */
-    public function setMaxLength (int $bytes) {
+    public function setMaxLength(int $bytes) {
         $this->maxLength = $bytes;
         return $this;
     }
@@ -307,7 +307,7 @@ 
      * @param int $opCode
      * @param string $payload
      */
-    public function write (int $opCode, string $payload): void {
+    public function write(int $opCode, string $payload): void {
         $offset = 0;
         $total = strlen($payload);
         do {
@@ -323,7 +323,7 @@ 
     /**
      * @param string $payload
      */
-    public function writeBinary (string $payload): void {
+    public function writeBinary(string $payload): void {
         $this->write(Frame::OP_BINARY, $payload);
     }
 
@@ -331,8 +331,8 @@ 
      * @param int $code
      * @param string $reason
      */
-    public function writeClose (int $code = Frame::CLOSE_NORMAL, string $reason = ''): void {
-        $this->writeFrame(true, Frame::OP_CLOSE, pack('n', $code) . $reason);
+    public function writeClose(int $code = Frame::CLOSE_NORMAL, string $reason = ''): void {
+        $this->writeFrame(true, Frame::OP_CLOSE, pack('n', $code).$reason);
     }
 
     /**
@@ -342,7 +342,7 @@ 
      * @param int $opCode
      * @param string $payload
      */
-    protected function writeFrame (bool $final, int $opCode, string $payload): void {
+    protected function writeFrame(bool $final, int $opCode, string $payload): void {
         if ($opCode & 0x08 and !$final) {
             throw new LogicException("Would have sent a fragmented control frame ({$opCode}) {$payload}");
         }
@@ -359,27 +359,27 @@ 
         else {
             $head .= chr($length);
         }
-        $this->client->write($head . $payload);
+        $this->client->write($head.$payload);
     }
 
     /**
      * @param string $payload
      */
-    public function writePing (string $payload = ''): void {
+    public function writePing(string $payload = ''): void {
         $this->writeFrame(true, Frame::OP_PING, $payload);
     }
 
     /**
      * @param string $payload
      */
-    public function writePong (string $payload = ''): void {
+    public function writePong(string $payload = ''): void {
         $this->writeFrame(true, Frame::OP_PONG, $payload);
     }
 
     /**
      * @param string $payload
      */
-    public function writeText (string $payload): void {
+    public function writeText(string $payload): void {
         $this->write(Frame::OP_TEXT, $payload);
     }
 }
\ No newline at end of file

Braces +10 added lines, -20 removed lines

@@ -117,12 +117,10 @@ 
         try {
             if ($this->continue === Frame::OP_TEXT) {
                 $this->onText($frame);
-            }
-            else {
+            } else {
                 $this->onBinary($frame);
             }
-        }
-        finally {
+        } finally {
             if ($frame->isFinal()) {
                 $this->continue = null;
             }
@@ -141,14 +139,11 @@ 
     protected function onControl (Frame $frame): void {
         if ($frame->isClose()) {
             $this->onClose($frame);
-        }
-        elseif ($frame->isPing()) {
+        } elseif ($frame->isPing()) {
             $this->onPing($frame);
-        }
-        elseif ($frame->isPong()) {
+        } elseif ($frame->isPong()) {
             $this->onPong($frame);
-        }
-        else {
+        } else {
             throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Unsupported control frame.", $frame);
         }
     }
@@ -162,8 +157,7 @@ 
         $this->onData_SetContinue($frame);
         if ($frame->isText()) {
             $this->onText($frame);
-        }
-        elseif ($frame->isBinary()) {
+        } elseif ($frame->isBinary()) {
             $this->onBinary($frame);
         }
     }
@@ -201,11 +195,9 @@ 
         $this->onFrame_CheckLength($frame);
         if ($frame->isControl()) {
             $this->onControl($frame);
-        }
-        elseif ($frame->isContinue()) {
+        } elseif ($frame->isContinue()) {
             $this->onContinue($frame);
-        }
-        else {
+        } else {
             $this->onData($frame);
         }
     }
@@ -351,12 +343,10 @@ 
         if ($length > 65535) {
             $head .= chr(127);
             $head .= pack('J', $length);
-        }
-        elseif ($length >= 126) {
+        } elseif ($length >= 126) {
             $head .= chr(126);
             $head .= pack('n', $length);
-        }
-        else {
+        } else {
             $head .= chr($length);
         }
         $this->client->write($head . $payload);

src/WebSocket/WebSocketServer.php

Spacing +13 added lines, -13 removed lines

@@ -31,7 +31,7 @@ 
      * @param $resource
      * @param Reactor $reactor
      */
-    public function __construct ($resource, Reactor $reactor) {
+    public function __construct($resource, Reactor $reactor) {
         parent::__construct($resource);
         $reactor->add($this);
         $this->reactor = $reactor;
@@ -40,7 +40,7 @@ 
     /**
      * @return WebSocketClient
      */
-    public function accept (): WebSocketClient {
+    public function accept(): WebSocketClient {
         /**
          * @see newClient()
          * @var WebSocketClient $client
@@ -57,7 +57,7 @@ 
      * @param int $opCode
      * @param string $payload
      */
-    public function broadcast (int $opCode, string $payload) {
+    public function broadcast(int $opCode, string $payload) {
         foreach ($this->clients as $client) {
             if ($client->isOk()) {
                 $client->getFrameHandler()->write($opCode, $payload);
@@ -68,7 +68,7 @@ 
     /**
      * @param string $payload
      */
-    public function broadcastBinary (string $payload) {
+    public function broadcastBinary(string $payload) {
         $this->broadcast(Frame::OP_BINARY, $payload);
     }
 
@@ -77,7 +77,7 @@ 
      *
      * @param string $payload
      */
-    public function broadcastPing (string $payload = '') {
+    public function broadcastPing(string $payload = '') {
         $this->broadcast(Frame::OP_PING, $payload);
     }
 
@@ -86,7 +86,7 @@ 
      *
      * @param string $text
      */
-    public function broadcastText (string $text) {
+    public function broadcastText(string $text) {
         $this->broadcast(Frame::OP_TEXT, $text);
     }
 
@@ -97,7 +97,7 @@ 
      * @param string $reason
      * @return $this
      */
-    public function close (int $code = Frame::CLOSE_INTERRUPT, $reason = '') {
+    public function close(int $code = Frame::CLOSE_INTERRUPT, $reason = '') {
         foreach ($this->clients as $client) {
             try {
                 $client->close($code, $reason); // clients remove themselves
@@ -115,14 +115,14 @@ 
      *
      * @return int
      */
-    public function count (): int {
+    public function count(): int {
         return count($this->clients);
     }
 
     /**
      * @return WebSocketClient[]
      */
-    public function getClients () {
+    public function getClients() {
         return $this->clients;
     }
 
@@ -130,21 +130,21 @@ 
      * @param resource $resource
      * @return WebSocketClient
      */
-    protected function newClient ($resource): WebSocketClient {
+    protected function newClient($resource): WebSocketClient {
         return new WebSocketClient($resource, $this);
     }
 
     /**
      * WebSocket servers never get OOB data.
      */
-    final public function onOutOfBand (): void {
+    final public function onOutOfBand(): void {
         // do nothing
     }
 
     /**
      * Auto-accept.
      */
-    public function onReadable (): void {
+    public function onReadable(): void {
         $this->accept();
     }
 
@@ -153,7 +153,7 @@ 
      *
      * @param WebSocketClient $client
      */
-    public function remove ($client): void {
+    public function remove($client): void {
         unset($this->clients[$client->getId()]);
         $this->reactor->remove($client);
     }

Braces +1 added lines, -2 removed lines

@@ -101,8 +101,7 @@
         foreach ($this->clients as $client) {
             try {
                 $client->close($code, $reason); // clients remove themselves
-            }
-            catch (Exception $e) {
+            } catch (Exception $e) {
                 continue;
             }
         }

src/Reactor.php

Spacing +8 added lines, -8 removed lines

@@ -31,12 +31,12 @@ 
      * @return int
      * @throws SocketError
      */
-    public static function select (array &$read, array &$write, array &$except, ?float $timeout = null): int {
+    public static function select(array &$read, array &$write, array &$except, ?float $timeout = null): int {
         $rwe = [$read, $write, $except];
         array_walk_recursive($rwe, function(SocketInterface &$each) {
             $each = $each->getResource();
         });
-        $uSec = (int)(fmod($timeout, 1) * 1000000); // ignored if timeout is null
+        $uSec = (int) (fmod($timeout, 1) * 1000000); // ignored if timeout is null
         $count = @socket_select($rwe[0], $rwe[1], $rwe[2], $timeout, $uSec); // keys are preserved
         if ($count === false) {
             $read = $write = $except = [];
@@ -54,7 +54,7 @@ 
      * @param ReactiveInterface $socket
      * @return $this
      */
-    public function add (ReactiveInterface $socket) {
+    public function add(ReactiveInterface $socket) {
         $this->sockets[$socket->getId()] = $socket;
         return $this;
     }
@@ -64,14 +64,14 @@ 
      *
      * @return int
      */
-    public function count (): int {
+    public function count(): int {
         return count($this->sockets);
     }
 
     /**
      * @return ReactiveInterface[]
      */
-    public function getSockets () {
+    public function getSockets() {
         return $this->sockets;
     }
 
@@ -80,7 +80,7 @@ 
      * @param ReactiveInterface $socket
      * @param Throwable $error
      */
-    public function onError (int $channel, $socket, Throwable $error): void {
+    public function onError(int $channel, $socket, Throwable $error): void {
         unset($channel);
         if ($socket instanceof WebSocketClient and $error instanceof WebSocketError) {
             $socket->close($error->getCode(), $error->getMessage());
@@ -101,7 +101,7 @@ 
      * @param float|null $timeout Maximum seconds to block. `NULL` blocks forever.
      * @return int Number of sockets selected.
      */
-    public function react (?float $timeout = null): int {
+    public function react(?float $timeout = null): int {
         /** @var ReactiveInterface[][] $rwe */
         $rwe = [$this->sockets, [], $this->sockets];
         $count = static::select($rwe[0], $rwe[1], $rwe[2], $timeout);
@@ -129,7 +129,7 @@ 
      * @param ReactiveInterface $socket
      * @return $this
      */
-    public function remove (ReactiveInterface $socket) {
+    public function remove(ReactiveInterface $socket) {
         unset($this->sockets[$socket->getId()]);
         return $this;
     }