+ ~jORt^RIHt^RIt^RIt^RIHt^RIHt^RI H t ^RI H t ] 'd^RI t ^RIHtHt^RIHt^R IHt!R R 4t!R R 4tR R .tR#)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)ThreadPoolExecutor)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypec>]tRt^tRtRRltRRltRRltRtR #) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.c V^8dQhRRRR/#)lockAsyncReadWriteLockreturnNone)formats"o/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/filelock/_async_read_write.py __annotate__-AsyncAcquireReadWriteReturnProxy.__annotate__s/Dc WnR#Nr)selfrs&&r__init__)AsyncAcquireReadWriteReturnProxy.__init__s rcV^8dQhRR/#)rrrr)rs"rrrs"4rc ""VP#5irrrs&r __aenter__+AsyncAcquireReadWriteReturnProxy.__aenter__syys c(V^8dQhRRRRRRRR/#) rexc_typeztype[BaseException] | None exc_valuezBaseException | None tracebackzTracebackType | Nonerrr)rs"rrrs2"","("( "  "rc V"VPP4GRjxL R#L5ir)rrelease)rr%r&r's&&&&r __aexit__*AsyncAcquireReadWriteReturnProxy.__aexit__s ii!!!s )')rN) __name__ __module__ __qualname____firstlineno____doc__rr"r*__static_attributes__rrrr r sO""rr c L]tRt^&tRtR%RRRRRRRR/RR lllt]R R l4t]R R l4t]RRl4t ]RRl4t ]RRl4t RRlt R%RR/RRlllt R%RR/RRllltRR/RRllt]R&RR/RRlll4t]R&RR/R R!lll4tR"R#ltR$tR#)'ra Async wrapper around :class:`ReadWriteLock` for use in ``asyncio`` applications. Because Python's :mod:`sqlite3` module has no async API, all blocking SQLite operations are dispatched to a thread pool via ``loop.run_in_executor()``. Reentrancy, upgrade/downgrade rules, and singleton behavior are delegated to the underlying :class:`ReadWriteLock`. :param lock_file: path to the SQLite database file used as the lock :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :param is_singleton: if ``True``, reuse existing :class:`ReadWriteLock` instances for the same resolved path :param loop: event loop for ``run_in_executor``; ``None`` uses the running loop :param executor: executor for ``run_in_executor``; ``None`` uses the default executor .. versionadded:: 3.21.0 blockingT is_singletonloopNexecutorc4V^8dQhRRRRRRRRRR R R R R /#)r lock_filezstr | os.PathLike[str]timeoutfloatr3boolr4r5 asyncio.AbstractEventLoop | Noner6futures.Executor | Nonerrr)rs"rrAsyncReadWriteLock.__annotate__9sY G G) G G  G  G/ G* G  Grc ~\WW4R7VnWPnVRJVnT;'g \ ^R7VnR#))r3r4N) max_workers)r_lock_loop_owns_executorr _executor)rr8r9r3r4r5r6s&&&$$$$rrAsyncReadWriteLock.__init__9s9#9d  &$.!FF%7A%FrcV^8dQhRR/#)rrstrr)rs"rrr>Is$$3$rc .VPP#)z$:returns: the path to the lock file.)rAr8r!s&rr8AsyncReadWriteLock.lock_fileHszz###rcV^8dQhRR/#)rrr:r)rs"rrr>Ns"""rc .VPP#)z:returns: the default timeout.)rAr9r!s&rr9AsyncReadWriteLock.timeoutMszz!!!rcV^8dQhRR/#)rrr;r)rs"rrr>Ss##$#rc .VPP#)z1:returns: whether blocking is enabled by default.)rAr3r!s&rr3AsyncReadWriteLock.blockingRszz"""rcV^8dQhRR/#)rrr<r)rs"rrr>Xs6rc VP#)z<:returns: the event loop (or ``None`` for the running loop).)rBr!s&rr5AsyncReadWriteLock.loopWszzrcV^8dQhRR/#)rrr=r)rs"rrr>]s1rc VP#)z5:returns: the executor (or ``None`` for the default).)rDr!s&rr6AsyncReadWriteLock.executor\s~~rc(V^8dQhRRRRRRRR/#)rfunczCallable[..., object]argsobjectkwargsrr)rs"rrr>as0dd4dVdvdZ`drc "VP;'g\P!4pVPVP\ P !V.VO5/VB4GRjxL #L5ir)rBasyncioget_running_looprun_in_executorrD functoolspartial)rrWrXrZr5s&&*, r_runAsyncReadWriteLock._runasSzz77W557))$..):K:KD:bSW:b[a:bccccsA!A*#A($A*c$V^8dQhRRRRRR/#rr9r:r3r;rr r)rs"rrr>es";;%;4;Ss;rc "VPVPPWR7GRjxL \VR7#L5i)a Acquire a shared read lock. See :meth:`ReadWriteLock.acquire_read` for full semantics. :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as an async context manager to release the lock :raises RuntimeError: if a write lock is already held on this instance :raises Timeout: if the lock cannot be acquired within *timeout* seconds r3Nr)rarA acquire_readr rr9r3s&&$rrgAsyncReadWriteLock.acquire_reades8ii //iLLL/T:: M+A>Ac$V^8dQhRRRRRR/#rdr)rs"rrr>ws";;5;D;Tt;rc "VPVPPWR7GRjxL \VR7#L5i)a Acquire an exclusive write lock. See :meth:`ReadWriteLock.acquire_write` for full semantics. :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as an async context manager to release the lock :raises RuntimeError: if a read lock is already held, or a write lock is held by a different thread :raises Timeout: if the lock cannot be acquired within *timeout* seconds rfNr)rarA acquire_writer rhs&&$rrm AsyncReadWriteLock.acquire_writews8ii 00'iMMM/T:: NrjforceFc V^8dQhRRRR/#)rror;rrr)rs"rrr>s 9 9d 9t 9rc p"VPVPPVR7GRjxL R#L5i)a  Release one level of the current lock. See :meth:`ReadWriteLock.release` for full semantics. :param force: if ``True``, release the lock completely regardless of the current lock level :raises RuntimeError: if no lock is currently held and *force* is ``False`` )roN)rarAr))rros&$rr)AsyncReadWriteLock.releases'ii **%i888s +646c$V^8dQhRRRRRR/#rr9z float | Noner3z bool | NonerzAsyncGenerator[None]r)rs"rrr>s"!!|!!`t!rc *"VfVPPpVfVPPpVPWR7GRjxL R5xVP 4GRjxL R#L$L TP 4GRjxL i;i5i)a[ Async context manager that acquires and releases a shared read lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default Nrf)rAr9r3rgr)rhs&&$r read_lockAsyncReadWriteLock.read_locksw ?jj((G  zz**H;;; ! ,,. < !$,,. HA B A1 BA5B*A3+B3B5B B  BBc$V^8dQhRRRRRR/#rtr)rs"rrr>s"!! !+!au!rc *"VfVPPpVfVPPpVPWR7GRjxL R5xVP 4GRjxL R#L$L TP 4GRjxL i;i5i)a` Async context manager that acquires and releases an exclusive write lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default Nrf)rAr9r3rmr)rhs&&$r write_lockAsyncReadWriteLock.write_locksw ?jj((G  zz**H   <<< ! ,,. = !$,,. rxcV^8dQhRR/#)rrrr)rs"rrr>s 0 0T 0rc "VPVPP4GRjxL VP'dVPP RR7R#R#L65i)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. NF)wait)rarAcloserCrDshutdownr!s&rrAsyncReadWriteLock.closesNii (()))     NN # # # /  *s)A$A"A$!A$)rDrArBrC)r)r,r-r.r/r0rpropertyr8r9r3r5r6rargrmr)rrvr{rr1rrrrr&s$ G  G " G26 G-1 G G$$""##d;$;;$;4;;$ 9U 9!W[!!(!X\!!( 0 0rr)r0 __future__rr\r_concurrent.futuresr contextlibrtypingr _read_writeroscollections.abcrr concurrentr typesr r r__all__rrrrsRK"1* & 8"#""$c0c0N' r