(self)
| 212 | return self.uwrite(buf) |
| 213 | |
| 214 | def uread(self): |
| 215 | if self.connect_to: |
| 216 | return None # still connecting |
| 217 | if self.shut_read: |
| 218 | return |
| 219 | self.rsock.setblocking(False) |
| 220 | try: |
| 221 | return _nb_clean(os.read, self.rsock.fileno(), 65536) |
| 222 | except OSError, e: |
| 223 | self.seterr('uread: %s' % e) |
| 224 | return '' # unexpected error... we'll call it EOF |
| 225 | |
| 226 | def fill(self): |
| 227 | if self.buf: |