resume polling on transport upgrade failure

Quobject · Aug 8, 2017 · be3634c · be3634c
1 parent 366c647
commit be3634c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/Src/EngineIoClientDotNet.mono/Client/Socket.cs b/Src/EngineIoClientDotNet.mono/Client/Socket.cs
@@ -836,6 +836,10 @@ void IListener.Call(params object[] args)
                             {
                                 if (_onTransportOpenListener.Parameters.Failed[0])
                                 {
+                                    // reset upgrading flag and resume polling
+                                    ((Polling)_onTransportOpenListener.Parameters.Socket.Transport).Resume();
+                                    _onTransportOpenListener.Parameters.Socket.Upgrading = false;
+                                    _onTransportOpenListener.Parameters.Socket.Flush();
                                     return;
                                 }
                                 if (ReadyStateEnum.CLOSED == _onTransportOpenListener.Parameters.Socket.ReadyState ||

diff --git a/Src/EngineIoClientDotNet.mono/Client/Transports/Polling.cs b/Src/EngineIoClientDotNet.mono/Client/Transports/Polling.cs
@@ -67,6 +67,12 @@ public void Pause(Action onPause)
             }
         }
 
+        public void Resume()
+        {
+            if (ReadyState == ReadyStateEnum.PAUSED)
+                ReadyState = ReadyStateEnum.OPEN;
+        }
+
         private class PauseEventDrainListener : IListener
         {
             private int[] total;