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