INNER CODE UNIT · Python

put

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

    def put(
        self,
        payload: dict[str, Any],
        completion: asyncio.Future[None] | None = None,
    ) -> None:
        reserved = 0
        counted = False
        text: str | None = None
        data: bytes | None = None
        frame: OutgoingFrame | None = None
        with self.lock:
            if self.closed:
                return
            self.producers += 1
        try:
            if completion is None:
                with self.lock:
                    reserved = payload_size(payload, BROADCAST_BYTES - self.used)

View source record →