| 269 | return self |
| 270 | |
| 271 | def __next__(self): |
| 272 | assert_(not self.closed, |
| 273 | "Iterator read after closed") |
| 274 | v = next(self.iterator) |
| 275 | if type(v) is not bytes: |
| 276 | assert_(False, "Iterator yielded non-bytestring (%r)" % (v,)) |
| 277 | if self.check_start_response is not None: |
| 278 | assert_(self.check_start_response, |
| 279 | "The application returns and we started iterating over its body, but start_response has not yet been called") |
| 280 | self.check_start_response = None |
| 281 | return v |
| 282 | |
| 283 | def close(self): |
| 284 | self.closed = True |