(self)
| 271 | @override |
| 272 | @catch_closed |
| 273 | async def receive_bytes(self) -> bytes: |
| 274 | msg = await self.websocket.receive() |
| 275 | if isinstance(msg, str): |
| 276 | raise TypeError("WebSocket received unexpected frame type: str") |
| 277 | return msg |
| 278 | |
| 279 | @override |
| 280 | async def send_text(self, data: str): |