INNER CODE UNIT · Python

_wake

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

    def _wake(self) -> None:
        with self.lock:
            self.wake_pending = False
            closed = self.closed
        self.available.set()
        if closed:
            self.closing.set()

    def fail(self) -> None:
        with self.lock:
            self.closed = True
            self._wake_locked()

    def register_response(self) -> asyncio.Future[None]:
        result = self.loop.create_future()
        self.responses.add(result)
        return result

View source record →