hfw / socket

src/Reactor.php

Spacing +9 added lines, -9 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;
     }
 
@@ -81,7 +81,7 @@ 
      * @param ReactiveInterface $socket
      * @return bool
      */
-    public function has (ReactiveInterface $socket): bool {
+    public function has(ReactiveInterface $socket): bool {
         return isset($sockets[$socket->getId()]);
     }
 
@@ -90,7 +90,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);
         echo "{$error}\n\n";
         if ($socket->isOpen()) {
@@ -113,7 +113,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);
@@ -142,7 +142,7 @@ 
      * @param ReactiveInterface $socket
      * @return $this
      */
-    public function remove (ReactiveInterface $socket) {
+    public function remove(ReactiveInterface $socket) {
         unset($this->sockets[$socket->getId()]);
         return $this;
     }

Braces +3 added lines, -6 removed lines

@@ -96,8 +96,7 @@ 
         if ($socket->isOpen()) {
             if ($socket instanceof WebSocketClient and $error instanceof WebSocketError) {
                 $socket->close($error->getCode(), $error->getMessage());
-            }
-            else {
+            } else {
                 $socket->close();
             }
         }
@@ -121,12 +120,10 @@ 
             foreach ($rwe[$channel] as $id => $socket) {
                 try {
                     $socket->{$method}();
-                }
-                catch (Throwable $error) {
+                } catch (Throwable $error) {
                     unset($rwe[0][$id]); // prevent onReadable() if this is an OOB error.
                     $this->onError($channel, $socket, $error);
-                }
-                finally {
+                } finally {
                     if (!$socket->isOpen() and $this->has($socket)) {
                         $this->remove($socket);
                     }