hfw / socket

src/WebSocket/HandShake.php

Braces +2 added lines, -4 removed lines

@@ -91,8 +91,7 @@ 
                 $value = trim($value);
                 if (isset($this->headers[$key])) {
                     $this->headers[$key] .= ', ' . $value;
-                }
-                else {
+                } else {
                     $this->headers[$key] = $value;
                 }
             }
@@ -101,8 +100,7 @@ 
             $this->upgrade();
             $this->client->write("\r\n\r\n");
             return true;
-        }
-        catch (WebSocketError $e) {
+        } catch (WebSocketError $e) {
             $this->client->write("HTTP/1.1 {$e->getCode()}\r\n\r\n");
             throw $e;
         }

src/AbstractClient.php

Braces +2 added lines, -4 removed lines

@@ -21,8 +21,7 @@ 
     public function __toString () {
         try {
             return implode(':', $this->getPeerName());
-        }
-        catch (Throwable $e) {
+        } catch (Throwable $e) {
             return "?{$this->resource}";
         }
     }
@@ -102,8 +101,7 @@ 
         while ($total < $length) {
             try {
                 $total += $this->awaitWritable()->send(substr($data, $total));
-            }
-            catch (SocketError $e) {
+            } catch (SocketError $e) {
                 $e->setExtra($total);
                 throw $e;
             }

src/SocketError.php

Braces +1 added lines, -2 removed lines

@@ -65,8 +65,7 @@
     public function __construct ($subject = null, $fallback = 0, SocketError $previous = null) {
         if ($errno = is_int($subject) ? $subject : static::getLast($subject)) {
             $message = socket_strerror($errno);
-        }
-        else {
+        } else {
             $errno = $fallback;
             $last = error_get_last();
             $message = "{$last['message']} in {$last['file']}:{$last['line']}";

src/AbstractSocket.php

Braces +2 added lines, -4 removed lines

@@ -52,11 +52,9 @@
     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()) {
+        } elseif (socket_get_option($resource, SOL_SOCKET, SO_TYPE) !== static::getType()) {
             throw new InvalidArgumentException('Invalid socket type for ' . static::class, SOCKET_ESOCKTNOSUPPORT);
-        }
-        elseif ($errno = SocketError::getLast($resource)) {
+        } elseif ($errno = SocketError::getLast($resource)) {
             // "File descriptor in bad state"
             throw new SocketError(SOCKET_EBADFD, 0, new SocketError($errno));
         }

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/WebSocket/FrameReader.php

Braces +3 added lines, -6 removed lines

@@ -67,11 +67,9 @@ 
                 ];
                 $this->buffer = substr($this->buffer, strlen($head[0]));
                 $this->validate();
-            }
-            elseif (strlen($this->buffer) >= 14) { // max head room
+            } elseif (strlen($this->buffer) >= 14) { // max head room
                 throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, 'Bad frame.');
-            }
-            else {
+            } else {
                 return null;
             }
         }
@@ -139,8 +137,7 @@ 
             if (!$this->head['final']) {
                 throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received fragmented {$name}");
             }
-        }
-        elseif ($opCode > Frame::OP_BINARY) { // data
+        } elseif ($opCode > Frame::OP_BINARY) { // data
             throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received {$name}");
         }
     }

Doc Comments +1 added lines, -1 removed lines

@@ -97,7 +97,7 @@
     /**
      * Yields all available frames from the peer.
      *
-     * @return Generator|Frame[]
+     * @return Generator
      */
     public function getFrames () {
         $this->buffer .= $this->client->recvAll();

src/AbstractServer.php

Braces +1 added lines, -2 removed lines

@@ -21,8 +21,7 @@
     public function __toString () {
         try {
             return implode(':', $this->getSockName());
-        }
-        catch (Throwable $e) {
+        } catch (Throwable $e) {
             return "?{$this->resource}";
         }
     }

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/Reactor.php

Braces +3 added lines, -6 removed lines

@@ -84,8 +84,7 @@ 
         unset($channel);
         if ($socket instanceof WebSocketClient and $error instanceof WebSocketError) {
             $socket->close($error->getCode(), $error->getMessage());
-        }
-        else {
+        } else {
             $socket->close();
         }
         echo $error;
@@ -109,11 +108,9 @@ 
             foreach ($rwe[$channel] as $id => $socket) {
                 try {
                     $socket->{$method}();
-                }
-                catch (Throwable $error) {
+                } catch (Throwable $error) {
                     $this->onError($channel, $socket, $error);
-                }
-                finally {
+                } finally {
                     if (!$socket->isOpen()) {
                         $this->remove($socket);
                     }

src/WebSocket/WebSocketClient.php

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