|
@ -443,11 +443,11 @@ class AsyncServer(server.Server): |
|
|
namespace_list = [namespace] |
|
|
namespace_list = [namespace] |
|
|
for n in namespace_list: |
|
|
for n in namespace_list: |
|
|
if n != '/' and self.manager.is_connected(sid, n): |
|
|
if n != '/' and self.manager.is_connected(sid, n): |
|
|
self.manager.pre_disconnect(sid, namespace=namespace) |
|
|
self.manager.pre_disconnect(sid, namespace=n) |
|
|
await self._trigger_event('disconnect', n, sid) |
|
|
await self._trigger_event('disconnect', n, sid) |
|
|
self.manager.disconnect(sid, n) |
|
|
self.manager.disconnect(sid, n) |
|
|
if namespace == '/' and self.manager.is_connected(sid, namespace): |
|
|
if namespace == '/' and self.manager.is_connected(sid, namespace): |
|
|
self.manager.pre_disconnect(sid, namespace=namespace) |
|
|
self.manager.pre_disconnect(sid, namespace='/') |
|
|
await self._trigger_event('disconnect', '/', sid) |
|
|
await self._trigger_event('disconnect', '/', sid) |
|
|
self.manager.disconnect(sid, '/') |
|
|
self.manager.disconnect(sid, '/') |
|
|
|
|
|
|
|
|