| @@ -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 |              if ($socket->isOpen()) { | 
| 102 | 101 | $socket->close(); | 
| 103 | 102 | } | 
| @@ -122,12 +121,10 @@ discard block | ||
| 122 | 121 |              foreach ($rwe[$channel] as $id => $socket) { | 
| 123 | 122 |                  try { | 
| 124 | 123 |                      $socket->{$method}(); | 
| 125 | - } | |
| 126 | -                catch (Throwable $error) { | |
| 124 | +                } catch (Throwable $error) { | |
| 127 | 125 | unset($rwe[0][$id]); // prevent onReadable() if this is an OOB error. | 
| 128 | 126 | $this->onError($channel, $socket, $error); | 
| 129 | - } | |
| 130 | -                finally { | |
| 127 | +                } finally { | |
| 131 | 128 |                      if (!$socket->isOpen() and $this->has($socket)) { | 
| 132 | 129 | $this->remove($socket); | 
| 133 | 130 | } |