(self)
| 91 | raise data |
| 92 | |
| 93 | async def as_response(self) -> Response: |
| 94 | while not self._receive_queue.empty(): |
| 95 | data = await self._receive_queue.get() |
| 96 | if isinstance(data, bytes): |
| 97 | self.response_data.extend(data) |
| 98 | return self.app.response_class( |
| 99 | bytes(self.response_data), self.status_code, self.headers |
| 100 | ) |
| 101 | |
| 102 | async def _asgi_receive(self) -> ASGIReceiveEvent: |
| 103 | return await self._send_queue.get() |
no test coverage detected