(self, timeout)
| 109 | |
| 110 | @contextmanager |
| 111 | def _timeout(self, timeout): |
| 112 | saved_timeout = self.socket.gettimeout() |
| 113 | try: |
| 114 | self.socket.settimeout(timeout) |
| 115 | yield |
| 116 | finally: |
| 117 | self.socket.settimeout(saved_timeout) |
| 118 | |
| 119 | def read_nonblocking(self, size=1, timeout=-1): |
| 120 | """ |