(self, 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: |
| 223 | context = { |
| 224 | 'message': ('An open stream was garbage collected prior to ' |
| 225 | 'establishing network connection; ' |
| 226 | 'call "stream.close()" explicitly.') |
| 227 | } |
| 228 | if self._source_traceback: |
| 229 | context['source_traceback'] = self._source_traceback |
| 230 | self._loop.call_exception_handler(context) |
| 231 | transport.abort() |
| 232 | return |
| 233 | self._transport = transport |
| 234 | reader = self._stream_reader |
| 235 | if reader is not None: |
| 236 | reader.set_transport(transport) |
| 237 | self._over_ssl = transport.get_extra_info('sslcontext') is not None |
| 238 | if self._client_connected_cb is not None: |
| 239 | writer = StreamWriter(transport, self, reader, self._loop) |
| 240 | res = self._client_connected_cb(reader, writer) |
| 241 | if coroutines.iscoroutine(res): |
| 242 | def callback(task): |
| 243 | if task.cancelled(): |
| 244 | transport.close() |
| 245 | return |
| 246 | exc = task.exception() |
| 247 | if exc is not None: |
| 248 | self._loop.call_exception_handler({ |
| 249 | 'message': 'Unhandled exception in client_connected_cb', |
| 250 | 'exception': exc, |
| 251 | 'transport': transport, |
| 252 | }) |
| 253 | transport.close() |
| 254 | |
| 255 | self._task = self._loop.create_task(res) |
| 256 | self._task.add_done_callback(callback) |
| 257 | |
| 258 | self._strong_reader = None |
| 259 | |
| 260 | def connection_lost(self, exc): |
| 261 | reader = self._stream_reader |
nothing calls this directly
no test coverage detected