litestar/connection/websocket.py lines 73 to 75
async def wrapped_receive() -> ReceiveMessage:
if self.connection_state == "disconnect":
raise WebSocketException(detail=DISCONNECT_MESSAGE)
litestar/connection/websocket.py lines 156 to 171
async def receive_data(self, mode: WebSocketMode) -> str | bytes:
"""Receive an 'websocket.receive' event and returns the data stored on it.
Args:
mode: The respective event key to use.
Returns:
The event's data.
"""
if self.connection_state == "init":
await self.accept()
event = cast("WebSocketReceiveEvent | WebSocketDisconnectEvent", await self.receive())
if event["type"] == "websocket.disconnect":
raise WebSocketDisconnect(detail="disconnect event", code=event["code"])
if self.connection_state == "disconnect":
raise WebSocketDisconnect(detail=DISCONNECT_MESSAGE)