(self, succeeded: SocketType | None)
| 330 | raise NotImplementedError |
| 331 | |
| 332 | def check(self, succeeded: SocketType | None) -> None: |
| 333 | # sockets only go into self.sockets when connect is called; make sure |
| 334 | # all the sockets that were created did in fact go in there. |
| 335 | assert self.socket_count == len(self.sockets) |
| 336 | |
| 337 | for ip, socket_ in self.sockets.items(): |
| 338 | assert ip in self.ip_dict |
| 339 | if socket_ is not succeeded: |
| 340 | assert socket_.closed |
| 341 | assert socket_.port == self.port |
| 342 | |
| 343 | |
| 344 | async def run_scenario( |
no outgoing calls
no test coverage detected