[Modify] Add it

This commit is contained in:
sta 2016-04-06 14:33:21 +09:00
parent 7772abd8f3
commit fe86f95d5e

View File

@ -465,6 +465,21 @@ namespace WebSocketSharp.Net
ares.Complete (ex);
}
private void cleanupWaitQueue (Exception exception)
{
HttpListenerAsyncResult[] aress = null;
lock (_waitQueueSync) {
if (_waitQueue.Count == 0)
return;
aress = _waitQueue.ToArray ();
_waitQueue.Clear ();
}
foreach (var ares in aress)
ares.Complete (exception);
}
private void close (bool force)
{
EndPointManager.RemoveListener (this);