(listener: socket.socket)
| 120 | self.buf = b"" |
| 121 | |
| 122 | def socket_handler(listener: socket.socket) -> None: |
| 123 | sock = listener.accept()[0] |
| 124 | |
| 125 | self.buf = sock.recv(65536) # We only accept one packet |
| 126 | done_receiving.set() # let the test know it can proceed |
| 127 | sock.close() |
| 128 | |
| 129 | self._start_server(socket_handler) |
| 130 | with HTTPSConnectionPool(self.host, self.port) as pool: |