INNER CODE UNIT · Python

send

ImFeH2/huddol · core/src/fora/adapters/websocket/server.py:211

    async def send(self, connection: web.WebSocketResponse) -> None:
        while (frame := await self.take()) is not None:
            try:
                await connection.send_str(frame.text)
                if frame.completion is not None:
                    self.complete(frame.completion)
            finally:
                frame.text = ""
                self.release(frame)
                del frame

    def close(self) -> None:
        with self.lock:
            self.closed = True
            while self.items:
                frame = self.items.popleft()
                frame.text = ""
                self.release(frame)

View source record →