(self, data: bytes)
| 52 | self._task: Awaitable[None] = None |
| 53 | |
| 54 | async def send(self, data: bytes) -> None: |
| 55 | await self._send_queue.put( |
| 56 | {"type": "http.request", "body": data, "more_body": True} |
| 57 | ) |
| 58 | |
| 59 | async def send_complete(self) -> None: |
| 60 | await self._send_queue.put( |