(self, receive: ASGIReceiveCallable)
| 197 | raise_task_exceptions(done) |
| 198 | |
| 199 | async def handle_messages(self, receive: ASGIReceiveCallable) -> None: |
| 200 | while True: |
| 201 | event = await receive() |
| 202 | if event["type"] == "websocket.receive": |
| 203 | message = event.get("bytes") or event["text"] |
| 204 | await websocket_received.send_async(message) |
| 205 | await self.queue.put(message) |
| 206 | elif event["type"] == "websocket.disconnect": |
| 207 | return |
| 208 | |
| 209 | def _create_websocket_from_scope(self, send: ASGISendCallable) -> Websocket: |
| 210 | headers = Headers() |