Fixed handling of Error::C_ASYNC_CONNECT_FAILED by the updates wrapper

WarriorXK · Jun 4, 2020 · 93d2f45 · 93d2f45
1 parent 0c6f417
commit 93d2f45
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/PHPWebSockets/UpdatesWrapper.php b/src/PHPWebSockets/UpdatesWrapper.php
@@ -261,7 +261,7 @@ public function update(float $timeout = NULL, array $tempStreams = []) {
                         $this->_onInvalidStream($update);
                         break;
                     case Update\Error::C_ASYNC_CONNECT_FAILED:
-                        $this->_onDisconnect($update);
+                        $this->_onAsyncConnectFailed($update);
                         break;
                     default:
                         throw new \UnexpectedValueException('Unknown or unsupported update code for error: ' . $code);
@@ -597,4 +597,13 @@ private function _onInvalidStream(Update\Error $update) {
     private function _onDisconnectDuringHandshake(Update\Error $update) {
         $this->_triggerErrorHandler($update->getSourceConnection(), $update->getCode());
     }
+
+    private function _onAsyncConnectFailed(Update\Error $update) {
+
+        $source = $update->getSourceConnection();
+
+        $this->_triggerDisconnectHandler($source, FALSE, NULL);
+        $this->_handledDisconnects[$source->getResourceIndex()] = TRUE;
+
+    }
 }