Skip to content

MultiLock

faststream.broker.handler.MultiLock #

MultiLock()
Source code in faststream/broker/handler.py 
378
379
def __init__(self) -> None:
    self.queue: "asyncio.Queue[None]" = asyncio.Queue()

empty property #

empty: bool

qsize property #

qsize: int

queue instance-attribute #

queue: asyncio.Queue[None] = asyncio.Queue()

wait_release async #

wait_release(timeout: Optional[float] = None) -> None
Source code in faststream/broker/handler.py 
398
399
400
401
async def wait_release(self, timeout: Optional[float] = None) -> None:
    if timeout:
        with anyio.move_on_after(timeout):
            await self.queue.join()