(self, *args, **kwargs)
| 84 | _write_queue_lock = None |
| 85 | |
| 86 | def __init__(self, *args, **kwargs): |
| 87 | Connection.__init__(self, *args, **kwargs) |
| 88 | |
| 89 | self._connect_socket() |
| 90 | self._socket.setblocking(0) |
| 91 | |
| 92 | self._write_queue = asyncio.Queue() |
| 93 | self._write_queue_lock = asyncio.Lock() |
| 94 | |
| 95 | # see initialize_reactor -- loop is running in a separate thread, so we |
| 96 | # have to use a threadsafe call |
| 97 | self._read_watcher = asyncio.run_coroutine_threadsafe( |
| 98 | self.handle_read(), loop=self._loop |
| 99 | ) |
| 100 | self._write_watcher = asyncio.run_coroutine_threadsafe( |
| 101 | self.handle_write(), loop=self._loop |
| 102 | ) |
| 103 | self._send_options_message() |
| 104 | |
| 105 | @classmethod |
| 106 | def initialize_reactor(cls): |
nothing calls this directly
no test coverage detected