Skip to content

Commit a830c9f

Browse files
Implement disconnect method for external processes (Fixes #684)
1 parent 37651d9 commit a830c9f

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

src/socketio/pubsub_manager.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,10 @@ def can_disconnect(self, sid, namespace):
7575
self._publish({'method': 'disconnect', 'sid': sid,
7676
'namespace': namespace or '/'})
7777

78+
def disconnect(self, sid, namespace=None):
79+
self._publish({'method': 'disconnect', 'sid': sid,
80+
'namespace': namespace or '/'})
81+
7882
def close_room(self, room, namespace=None):
7983
self._publish({'method': 'close_room', 'room': room,
8084
'namespace': namespace or '/'})

tests/common/test_pubsub_manager.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,12 @@ def test_can_disconnect(self):
169169
{'method': 'disconnect', 'sid': sid, 'namespace': '/foo'}
170170
)
171171

172+
def test_disconnect(self):
173+
self.pm.disconnect('foo')
174+
self.pm._publish.assert_called_once_with(
175+
{'method': 'disconnect', 'sid': 'foo', 'namespace': '/'}
176+
)
177+
172178
def test_close_room(self):
173179
self.pm.close_room('foo')
174180
self.pm._publish.assert_called_once_with(

0 commit comments

Comments
 (0)