(self, *args, **kwargs)
| 95 | cls._new_timer.clear() |
| 96 | |
| 97 | def __init__(self, *args, **kwargs): |
| 98 | Connection.__init__(self, *args, **kwargs) |
| 99 | self.uses_legacy_ssl_options = self.ssl_options and not self.ssl_context |
| 100 | self._write_queue = Queue() |
| 101 | |
| 102 | self._connect_socket() |
| 103 | |
| 104 | self._read_watcher = eventlet.spawn(lambda: self.handle_read()) |
| 105 | self._write_watcher = eventlet.spawn(lambda: self.handle_write()) |
| 106 | self._send_options_message() |
| 107 | |
| 108 | def _wrap_socket_from_context(self): |
| 109 | _check_pyopenssl() |
nothing calls this directly
no test coverage detected