(self, *args, **kwargs)
| 70 | timer_event.clear() |
| 71 | |
| 72 | def __init__(self, *args, **kwargs): |
| 73 | Connection.__init__(self, *args, **kwargs) |
| 74 | |
| 75 | self._write_queue = Queue() |
| 76 | |
| 77 | self._connect_socket() |
| 78 | |
| 79 | self._read_watcher = gevent.spawn(self.handle_read) |
| 80 | self._write_watcher = gevent.spawn(self.handle_write) |
| 81 | self._send_options_message() |
| 82 | |
| 83 | def close(self): |
| 84 | with self.lock: |
nothing calls this directly
no test coverage detected