hfw / socket

src/AbstractSocket.php

Doc Comments +2 added lines, -2 removed lines

@@ -151,7 +151,7 @@ 
      * @see https://php.net/socket_get_option
      *
      * @param int $option `SO_*` option constant.
-     * @return mixed The option's value. This is never `false`.
+     * @return integer The option's value. This is never `false`.
      * @throws SocketError
      */
     public function getOption (int $option) {
@@ -213,7 +213,7 @@ 
      * @see await()
      *
      * @param int $channel `SocketInterface` channel constant.
-     * @param float|null $timeout Maximum seconds to block. `NULL` blocks forever. Defaults to a poll.
+     * @param integer $timeout Maximum seconds to block. `NULL` blocks forever. Defaults to a poll.
      * @return bool
      * @throws SocketError
      */

src/StreamClient.php

Doc Comments +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
      * @see https://php.net/socket_create_pair
      *
      * @param array $extra Variadic constructor arguments.
-     * @return static[] Two instances at indices `0` and `1`.
+     * @return StreamClient[] Two instances at indices `0` and `1`.
      * @throws SocketError
      */
     public static function newUnixPair (...$extra) {

Braces +2 added lines, -4 removed lines

@@ -52,8 +52,7 @@ 
                 $length -= $chunkSize = strlen($chunk);
             } while ($chunkSize and $length);
             return $data;
-        }
-        catch (SocketError $e) {
+        } catch (SocketError $e) {
             $e->setExtra($data);
             throw $e;
         }
@@ -90,8 +89,7 @@ 
         $length = $this->getOption(SO_RCVBUF);
         try {
             return $this->recv($length, $flags);
-        }
-        catch (SocketError $e) {
+        } catch (SocketError $e) {
             if ($e->getCode() === SOCKET_EAGAIN) { // would block
                 return '';
             }

src/WebSocket/FrameHandler.php

Braces +8 added lines, -16 removed lines

@@ -118,8 +118,7 @@ 
                         $frame
                     );
             }
-        }
-        finally {
+        } finally {
             if ($frame->isFinal()) {
                 $this->continue = null;
             }
@@ -138,11 +137,9 @@ 
     protected function onControl (Frame $control): void {
         if ($control->isClose()) {
             $this->onClose($control);
-        }
-        elseif ($control->isPing()) {
+        } elseif ($control->isPing()) {
             $this->onPing($control);
-        }
-        elseif ($control->isPong()) {
+        } elseif ($control->isPong()) {
             $this->onPong($control);
         }
     }
@@ -156,8 +153,7 @@ 
         $this->onData_SetContinue($data);
         if ($data->isText()) {
             $this->onText($data);
-        }
-        elseif ($data->isBinary()) {
+        } elseif ($data->isBinary()) {
             $this->onBinary($data);
         }
     }
@@ -188,11 +184,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);
         }
     }
@@ -336,12 +330,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);