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