| 53 | |
| 54 | |
| 55 | class ASGIResponseStream(AsyncByteStream): |
| 56 | def __init__(self, body: list[bytes]) -> None: |
| 57 | self._body = body |
| 58 | |
| 59 | async def __aiter__(self) -> typing.AsyncIterator[bytes]: |
| 60 | yield b"".join(self._body) |
| 61 | |
| 62 | |
| 63 | class ASGITransport(AsyncBaseTransport): |
no outgoing calls
no test coverage detected