| 28 | |
| 29 | |
| 30 | class WSGIByteStream(SyncByteStream): |
| 31 | def __init__(self, result: typing.Iterable[bytes]) -> None: |
| 32 | self._close = getattr(result, "close", None) |
| 33 | self._result = _skip_leading_empty_chunks(result) |
| 34 | |
| 35 | def __iter__(self) -> typing.Iterator[bytes]: |
| 36 | for part in self._result: |
| 37 | yield part |
| 38 | |
| 39 | def close(self) -> None: |
| 40 | if self._close is not None: |
| 41 | self._close() |
| 42 | |
| 43 | |
| 44 | class WSGITransport(BaseTransport): |