Merge pull request #47 from MeTaXaS4/master

handle the emit in try/catch

Author: mattqs

Src/EngineIoClientDotNet.mono/Client/Socket.cs

@@ -445,7 +445,7 @@ private bool Flush()
             var log = LogManager.GetLogger(Global.CallerName());
 
             log.Info(string.Format("ReadyState={0} Transport.Writeable={1} Upgrading={2} WriteBuffer.Count={3}",ReadyState,Transport.Writable,Upgrading, WriteBuffer.Count));
-            if (ReadyState != ReadyStateEnum.CLOSED && this.Transport.Writable && !Upgrading && WriteBuffer.Count != 0)
+            if (ReadyState != ReadyStateEnum.CLOSED && ReadyState == ReadyStateEnum.OPEN && this.Transport.Writable && !Upgrading && WriteBuffer.Count != 0)
             {
                 log.Info(string.Format("Flush {0} packets in socket", WriteBuffer.Count));
                 PrevBufferLen = WriteBuffer.Count;

Src/EngineIoClientDotNet.mono/ComponentEmitter/Emitter.cs

@@ -34,11 +34,16 @@ public virtual Emitter Emit(string eventString, params object[] args)
             //log.Info("Emitter emit event = " + eventString);
             if (this.callbacks.ContainsKey(eventString))
             {
-                ImmutableList<IListener> callbacksLocal = this.callbacks[eventString];                
-                foreach (var fn in callbacksLocal)
+                try
                 {
-                    fn.Call(args);
-                }                    
+                    //handle in try/catch the emit
+                    ImmutableList<IListener> callbacksLocal = this.callbacks[eventString];
+                    foreach (var fn in callbacksLocal)
+                    {
+                        fn.Call(args);
+                    }
+                }
+                catch { }
             }
             return this;            
         }