(self, timeout)
| 1667 | self._event.set() |
| 1668 | |
| 1669 | def wait(self, timeout): |
| 1670 | self._event.wait(timeout) |
| 1671 | if self._event.is_set(): |
| 1672 | if self._exception: |
| 1673 | raise self._exception |
| 1674 | else: |
| 1675 | raise OperationTimedOut("Connection heartbeat timeout after %s seconds" % (timeout,), self.connection.endpoint) |
| 1676 | |
| 1677 | def _options_callback(self, response): |
| 1678 | if isinstance(response, SupportedMessage): |