Skip to content

Commit c0c1bf8

Browse files
properly handle disconnects from ios client
1 parent ac7fa5c commit c0c1bf8

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

socketio/asyncio_server.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -409,8 +409,6 @@ async def _handle_disconnect(self, sid, namespace):
409409
if namespace == '/' and self.manager.is_connected(sid, namespace):
410410
await self._trigger_event('disconnect', '/', sid)
411411
self.manager.disconnect(sid, '/')
412-
if sid in self.environ:
413-
del self.environ[sid]
414412

415413
async def _handle_event(self, sid, namespace, id, data):
416414
"""Handle an incoming client event."""
@@ -505,6 +503,8 @@ async def _handle_eio_message(self, sid, data):
505503
async def _handle_eio_disconnect(self, sid):
506504
"""Handle Engine.IO disconnect event."""
507505
await self._handle_disconnect(sid, '/')
506+
if sid in self.environ:
507+
del self.environ[sid]
508508

509509
def _engineio_server_class(self):
510510
return engineio.AsyncServer

socketio/server.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -583,8 +583,6 @@ def _handle_disconnect(self, sid, namespace):
583583
if namespace == '/' and self.manager.is_connected(sid, namespace):
584584
self._trigger_event('disconnect', '/', sid)
585585
self.manager.disconnect(sid, '/')
586-
if sid in self.environ:
587-
del self.environ[sid]
588586

589587
def _handle_event(self, sid, namespace, id, data):
590588
"""Handle an incoming client event."""
@@ -673,6 +671,8 @@ def _handle_eio_message(self, sid, data):
673671
def _handle_eio_disconnect(self, sid):
674672
"""Handle Engine.IO disconnect event."""
675673
self._handle_disconnect(sid, '/')
674+
if sid in self.environ:
675+
del self.environ[sid]
676676

677677
def _engineio_server_class(self):
678678
return engineio.Server

0 commit comments

Comments
 (0)