(self, message: dict[str, Any])
| 1408 | return self.response |
| 1409 | |
| 1410 | def put_message(self, message: dict[str, Any]) -> None: |
| 1411 | self.app_queue.put_nowait(message) |
| 1412 | |
| 1413 | async def receive(self) -> dict[str, Any]: |
| 1414 | """Receive messages in the queue.""" |