()
| 1083 | c.connect = mock.AsyncMock(side_effect=exceptions.ConnectionError) |
| 1084 | |
| 1085 | async def r(): |
| 1086 | task = c.start_background_task(c._handle_reconnect) |
| 1087 | await asyncio.sleep(0.1) |
| 1088 | await c.shutdown() |
| 1089 | await task |
| 1090 | |
| 1091 | await r() |
| 1092 | c._trigger_event.assert_awaited_once_with('__disconnect_final', |
nothing calls this directly
no test coverage detected