hfw / socket

src/AbstractSocket.php

Braces +3 added lines, -6 removed lines

@@ -61,11 +61,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('The given socket resource is of the wrong type for ' . get_class(), SOCKET_ESOCKTNOSUPPORT);
-        }
-        elseif ($errno = SocketError::getLast($resource)) {
+        } elseif ($errno = SocketError::getLast($resource)) {
             $error = new SocketError(SOCKET_EBADFD);
             $error->setExtra($errno);
             throw $error;
@@ -289,8 +287,7 @@ 
     public function setBlocking ($blocking) {
         if ($blocking) {
             $success = @socket_set_block($this->resource);
-        }
-        else {
+        } else {
             $success = @socket_set_nonblock($this->resource);
         }
         if (!$success) {

src/StreamClient.php

Braces +2 added lines, -4 removed lines

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

src/Reactor.php

Braces +1 added lines, -2 removed lines

@@ -93,8 +93,7 @@
             foreach ($rwe[0] as $id => $socket) {
                 $socket->onReadable();
             }
-        }
-        finally {
+        } finally {
             array_walk_recursive($rwe, function(ReactiveInterface $each) {
                 if (!$each->isOpen()) {
                     $this->remove($each);

src/AbstractServer.php

Braces +1 added lines, -2 removed lines

@@ -19,8 +19,7 @@
     public function __toString () {
         try {
             return implode(':', $this->getSockName());
-        }
-        catch (Exception $exception) {
+        } catch (Exception $exception) {
             return ':';
         }
     }

src/AbstractClient.php

Braces +2 added lines, -4 removed lines

@@ -19,8 +19,7 @@ 
     public function __toString () {
         try {
             return implode(':', $this->getPeerName());
-        }
-        catch (Exception $exception) {
+        } catch (Exception $exception) {
             return ':';
         }
     }
@@ -102,8 +101,7 @@ 
         while ($total < $length) {
             try {
                 $total += $this->awaitWritable()->send(substr($data, $total));
-            }
-            catch (SocketError $error) {
+            } catch (SocketError $error) {
                 $error->setExtra($total);
                 throw $error;
             }

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

Braces +1 added lines, -2 removed lines

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

src/WebSocket/WebSocketClient.php

Braces +3 added lines, -6 removed lines

@@ -81,8 +81,7 @@ 
                 $this->getFrameHandler()->write($payload, Frame::OP_CLOSE);
                 $this->shutdown(self::CH_WRITE);
             }
-        }
-        finally {
+        } finally {
             $this->state = self::STATE_CLOSE;
             $this->server->remove($this);
             parent::close();
@@ -174,12 +173,10 @@ 
                 case self::STATE_CLOSE:
                     return;
             }
-        }
-        catch (WebSocketError $e) {
+        } catch (WebSocketError $e) {
             $this->close($e->getCode(), $e->getMessage());
             throw $e;
-        }
-        catch (Exception $e) {
+        } catch (Exception $e) {
             $this->close(Frame::CLOSE_INTERNAL_ERROR);
             throw $e;
         }

src/WebSocket/FrameHandler.php

Braces +9 added lines, -18 removed lines

@@ -48,8 +48,7 @@ 
         $handler = $this->client->getMessageHandler();
         if ($handler->isBinaryStream()) {
             $handler->onBinary($binary->getPayload());
-        }
-        else {
+        } else {
             if (strlen($this->binary) + $binary->getLength() > $handler->getMaxLength()) {
                 throw new WebSocketError(Frame::CLOSE_TOO_LARGE, $handler->getMaxLength(), $binary);
             }
@@ -111,11 +110,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);
         }
     }
@@ -128,8 +125,7 @@ 
     protected function onData (Frame $data): void {
         if ($data->isText()) {
             $this->onText($data);
-        }
-        elseif ($data->isBinary()) {
+        } elseif ($data->isBinary()) {
             $this->onBinary($data);
         }
     }
@@ -146,11 +142,9 @@ 
         $frame->validate();
         if ($frame->isControl()) {
             $this->onControl($frame);
-        }
-        elseif ($frame->isContinue()) {
+        } elseif ($frame->isContinue()) {
             $this->onContinue($frame);
-        }
-        else {
+        } else {
             $this->onData($frame);
         }
     }
@@ -200,8 +194,7 @@ 
         $handler = $this->client->getMessageHandler();
         if ($handler->isTextStream()) {
             $handler->onText($text->getPayload());
-        }
-        else {
+        } else {
             if (strlen($this->text) + $text->getLength() > $handler->getMaxLength()) {
                 throw new WebSocketError(Frame::CLOSE_TOO_LARGE, $handler->getMaxLength(), $text);
             }
@@ -227,12 +220,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);