INNER CODE UNIT · Python

complete

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

    def complete(self, result: asyncio.Future[None]) -> None:
        if not result.done():
            result.set_result(None)
        self.responses.discard(result)

    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

View source record →