(self, transport)
| 1072 | |
| 1073 | class ServerProtocol(asyncio.StreamReaderProtocol): |
| 1074 | def connection_made(self, transport): |
| 1075 | super_ = super() |
| 1076 | transport.pause_reading() |
| 1077 | fut = self._loop.create_task(self._loop.start_tls( |
| 1078 | transport, self, sslctx_2, server_side=True)) |
| 1079 | |
| 1080 | def cb(_): |
| 1081 | try: |
| 1082 | tr = fut.result() |
| 1083 | except Exception as ex: |
| 1084 | super_.connection_lost(ex) |
| 1085 | else: |
| 1086 | super_.connection_made(tr) |
| 1087 | fut.add_done_callback(cb) |
| 1088 | |
| 1089 | def server_protocol_factory(): |
| 1090 | reader = asyncio.StreamReader() |
nothing calls this directly
no test coverage detected