| 1256 | backend_pid, backend_secret): |
| 1257 | |
| 1258 | class CancelProto(asyncio.Protocol): |
| 1259 | |
| 1260 | def __init__(self): |
| 1261 | self.on_disconnect = _create_future(loop) |
| 1262 | self.is_ssl = False |
| 1263 | |
| 1264 | def connection_lost(self, exc): |
| 1265 | if not self.on_disconnect.done(): |
| 1266 | self.on_disconnect.set_result(True) |
| 1267 | |
| 1268 | if isinstance(addr, str): |
| 1269 | tr, pr = await loop.create_unix_connection(CancelProto, addr) |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…