Method decode

starlette/endpoints.py:91–117

(self, websocket: WebSocket, message: Message)

            await self.on_disconnect(websocket, close_code)

    async def decode(self, websocket: WebSocket, message: Message) -> Any:
        if self.encoding == class="st">"text":
            if class="st">"text" not in message:
                await websocket.close(code=status.WS_1003_UNSUPPORTED_DATA)
                raise RuntimeError(class="st">"Expected text websocket messages, but got bytes")
            return message[class="st">"text"]

        elif self.encoding == class="st">"bytes":
            if class="st">"bytes" not in message:
                await websocket.close(code=status.WS_1003_UNSUPPORTED_DATA)
                raise RuntimeError(class="st">"Expected bytes websocket messages, but got text")
            return message[class="st">"bytes"]

        elif self.encoding == class="st">"json":
            if message.get(class="st">"text") is not None:
                text = message[class="st">"text"]
            else:
                text = message[class="st">"bytes"].decode(class="st">"utf-8")

            try:
                return json.loads(text)
            except json.decoder.JSONDecodeError:
                await websocket.close(code=status.WS_1003_UNSUPPORTED_DATA)
                raise RuntimeError(class="st">"Malformed JSON data received.")

        assert self.encoding is None, fclass="st">"Unsupported &class="cm">#x27;encoding' attribute {self.encoding}"
        return message[class="st">"text"] if message.get(class="st">"text") else message[class="st">"bytes"]

    async def on_connect(self, websocket: WebSocket) -> None:
        class="st">""class="st">"Override to handle an incoming websocket connection"class="st">""