(self, transport)
| 214 | return self._stream_reader_wr() |
| 215 | |
| 216 | def _replace_transport(self, transport): |
| 217 | loop = self._loop |
| 218 | self._transport = transport |
| 219 | self._over_ssl = transport.get_extra_info('sslcontext') is not None |
| 220 | |
| 221 | def connection_made(self, transport): |
| 222 | if self._reject_connection: |
no test coverage detected