@@ -95,8 +95,7 @@ discard block |
||
| 95 | 95 | if ($socket->isOpen()) { |
| 96 | 96 | if ($socket instanceof WebSocketClient and $error instanceof WebSocketError) { |
| 97 | 97 | $socket->close($error->getCode(), $error->getMessage()); |
| 98 | - } |
|
| 99 | - else { |
|
| 98 | + } else { |
|
| 100 | 99 | echo "{$error}\n\n"; |
| 101 | 100 | $socket->close(); |
| 102 | 101 | } |
@@ -121,12 +120,10 @@ discard block |
||
| 121 | 120 | foreach ($rwe[$channel] as $id => $socket) { |
| 122 | 121 | try { |
| 123 | 122 | $socket->{$method}(); |
| 124 | - } |
|
| 125 | - catch (Throwable $error) { |
|
| 123 | + } catch (Throwable $error) { |
|
| 126 | 124 | unset($rwe[0][$id]); // prevent onReadable() if this is an OOB error. |
| 127 | 125 | $this->onError($channel, $socket, $error); |
| 128 | - } |
|
| 129 | - finally { |
|
| 126 | + } finally { |
|
| 130 | 127 | if (!$socket->isOpen() and $this->has($socket)) { |
| 131 | 128 | $this->remove($socket); |
| 132 | 129 | } |