@@ -84,8 +84,7 @@ discard block |
||
| 84 | 84 | unset($channel); |
| 85 | 85 | if ($socket instanceof WebSocketClient and $error instanceof WebSocketError) { |
| 86 | 86 | $socket->close($error->getCode(), $error->getMessage()); |
| 87 | - } |
|
| 88 | - else { |
|
| 87 | + } else { |
|
| 89 | 88 | $socket->close(); |
| 90 | 89 | } |
| 91 | 90 | echo $error; |
@@ -109,11 +108,9 @@ discard block |
||
| 109 | 108 | foreach ($rwe[$channel] as $id => $socket) { |
| 110 | 109 | try { |
| 111 | 110 | $socket->{$method}(); |
| 112 | - } |
|
| 113 | - catch (Throwable $error) { |
|
| 111 | + } catch (Throwable $error) { |
|
| 114 | 112 | $this->onError($channel, $socket, $error); |
| 115 | - } |
|
| 116 | - finally { |
|
| 113 | + } finally { |
|
| 117 | 114 | if (!$socket->isOpen()) { |
| 118 | 115 | $this->remove($socket); |
| 119 | 116 | } |