(self)
| 62 | ) |
| 63 | |
| 64 | async def receive(self) -> bytes: |
| 65 | data = await self._receive_queue.get() |
| 66 | if isinstance(data, Exception): |
| 67 | raise data |
| 68 | else: |
| 69 | return data |
| 70 | |
| 71 | async def disconnect(self) -> None: |
| 72 | await self._send_queue.put({"type": "http.disconnect"}) |