(self, eio)
| 69 | assert s.handlers['/foo']['disconnect'] == bar |
| 70 | |
| 71 | async def test_emit(self, eio): |
| 72 | mgr = self._get_mock_manager() |
| 73 | s = async_server.AsyncServer(client_manager=mgr) |
| 74 | await s.emit( |
| 75 | 'my event', |
| 76 | {'foo': 'bar'}, |
| 77 | to='room', |
| 78 | skip_sid='123', |
| 79 | namespace='/foo', |
| 80 | callback='cb', |
| 81 | ) |
| 82 | s.manager.emit.assert_awaited_once_with( |
| 83 | 'my event', |
| 84 | {'foo': 'bar'}, |
| 85 | '/foo', |
| 86 | room='room', |
| 87 | skip_sid='123', |
| 88 | callback='cb', |
| 89 | ignore_queue=False, |
| 90 | ) |
| 91 | await s.emit( |
| 92 | 'my event', |
| 93 | {'foo': 'bar'}, |
| 94 | room='room', |
| 95 | skip_sid='123', |
| 96 | namespace='/foo', |
| 97 | callback='cb', |
| 98 | ignore_queue=True, |
| 99 | ) |
| 100 | s.manager.emit.assert_awaited_with( |
| 101 | 'my event', |
| 102 | {'foo': 'bar'}, |
| 103 | '/foo', |
| 104 | room='room', |
| 105 | skip_sid='123', |
| 106 | callback='cb', |
| 107 | ignore_queue=True, |
| 108 | ) |
| 109 | |
| 110 | async def test_emit_default_namespace(self, eio): |
| 111 | mgr = self._get_mock_manager() |
nothing calls this directly
no test coverage detected