INNER CODE UNIT · Python

broadcast

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

    def broadcast(self, payload: dict[str, Any]) -> None:
        self.put(payload)

    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:

View source record →