+
    ~j&  c                    a  0 t $ ^ RIHt ^ RIt^ RIHu Ht R t	^ RI
t
^ RIHt ^ RIHt ^ RIHtHtHtHtHtHt ^ R	IHt ^R
IHt ^RIHt ]! R4      t]! R4      tR R ltR R ltR R lt ]]! RRR7       ! R R4      4       4       t!R R lt"]! 4       t#R]$R&    ! R R]
PJ                  4      t& ! R R]],          4      t' ! R R]],          4      t(R# )!    )annotationsNEventLoopTokenRunvarTokenRunVar)	dataclass)TracebackType)AnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend)AsyncBackendTDc                   V ^8  d   QhRR/#    returnNone )formats   "c/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anyio/lowlevel.py__annotate__r      s     + +$ +    c                 R   "   \        4       P                  4       G Rj  xL
  R#  L5i)z
Check for cancellation and allow the scheduler to switch to another task.

Equivalent to (but more efficient than)::

    await checkpoint_if_cancelled()
    await cancel_shielded_checkpoint()

.. versionadded:: 3.0

N)r   
checkpointr   r   r   r   r      s      

(
(
***   '%'c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   )   s     	8 	8t 	8r   c                 R   "   \        4       P                  4       G Rj  xL
  R#  L5i)z
Enter a checkpoint if the enclosing cancel scope has been cancelled.

This does not allow the scheduler to switch to a different task.

.. versionadded:: 3.0

N)r   checkpoint_if_cancelledr   r   r   r"   r"   )   s      

5
5
777r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   5   s     ; ;$ ;r   c                 R   "   \        4       P                  4       G Rj  xL
  R#  L5i)z
Allow the scheduler to switch to another task but without checking for cancellation.

Equivalent to (but potentially more efficient than)::

    with CancelScope(shield=True):
        await checkpoint()

.. versionadded:: 3.0

N)r   cancel_shielded_checkpointr   r   r   r%   r%   5   s      

8
8
:::r   TF)frozenreprc                  0    ] tR t^Dt$ RtR]R&   R]R&   RtR# )r   zU
An opaque object that holds a reference to an event loop.

.. versionadded:: 4.11.0
ztype[AsyncBackend]backend_classobjectnative_tokenr   N)__name__
__module____qualname____firstlineno____doc____annotations____static_attributes__r   r   r   r   r   D   s     &%r   c                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r   Q   s     4 4~ 4r   c                 L    \        4       p V P                  4       p\        W4      # )z
Return a token object that can be used to call code in the current event loop from
another thread.

:raises NoEventLoopError: if no supported asynchronous event loop is running in the
    current thread

.. versionadded:: 4.11.0

)r   current_tokenr   )r)   	raw_tokens     r   r5   r5   Q   s%     &'M++-I-33r   z1WeakKeyDictionary[object, dict[RunVar[Any], Any]]	_run_varsc                  8    ] tR t^dt]P
                  ! 4       tRtR# )_NoValueSetr   N)r,   r-   r.   r/   enumautoNO_VALUE_SETr2   r   r   r   r9   r9   d   s    99;Lr   r9   c                  >    ] tR t^htR	tR R ltR R ltR R ltRtR# )
r   c                    V ^8  d   QhRRRR/# )r   varz	RunVar[T]value%T | Literal[_NoValueSet.NO_VALUE_SET]r   )r   s   "r   r   RunvarToken.__annotate__k   s      I .S r   c                	,    Wn         W n        R V n        R# )FN_var_value	_redeemed)selfr?   r@   s   &&&r   __init__RunvarToken.__init__k   s    	=Br   c                   V ^8  d   QhRR/# )r   r   RunvarToken[T]r   )r   s   "r   r   rB   p   s      > r   c                	    V # Nr   rH   s   &r   	__enter__RunvarToken.__enter__p   s    r   c               (    V ^8  d   QhRRRRRRRR/# )	r   exc_typeztype[BaseException] | Noneexc_valzBaseException | Noneexc_tbzTracebackType | Noner   r   r   )r   s   "r   r   rB   s   s2      , & %	
 
r   c                	<    V P                   P                  V 4       R # rN   )rE   reset)rH   rS   rT   rU   s   &&&&r   __exit__RunvarToken.__exit__s   s     			r   )rG   rF   rE   NrD   )	r,   r-   r.   r/   	__slots__rI   rP   rX   r2   r   r   r   r   r   h   s    -I
 r   c                      ] tR t^|t$ RtRt]P                  tR]R&   ]3R R llt	]
R R l4       t]R R	 l4       t]R
 R l4       t]3R R lltR R ltR R ltR R ltRtR# )r   z
Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop.

Can be used as a context manager, Just like :class:`~contextvars.ContextVar`, that
will reset the variable to its previous value when the context block is exited.
z!Literal[_NoValueSet.NO_VALUE_SET]r<   c                    V ^8  d   QhRRRR/# )r   namestrdefaultrA   r   )r   s   "r   r   RunVar.__annotate__   s         "G r   c                	    Wn         W n        R # rN   _name_default)rH   r]   r_   s   &&&r   rI   RunVar.__init__   s     
r   c                   V ^8  d   QhRR/# )r   r   zdict[RunVar[T], T]r   )r   s   "r   r   r`      s      1 r   c                	    \        4       P                  p \        V,          #   \         d    / ;p\        T&   Tu # i ; irN   )r5   r+   r7   KeyError)rH   r+   run_varss   &  r   _current_varsRunVar._current_vars   sB    $33	\** 	133Hy.O	s   # >>c                    V ^8  d   QhRRRR/# )r   r_   r   r   T | Dr   )r   s   "r   r   r`      s    ++1++r   c                	    R # rN   r   rH   r_   s   &&r   get
RunVar.get   s    (+r   c                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r`      s    Qr   c                	    R # rN   r   rO   s   &r   rp   rq      s    r   c                    V ^8  d   QhRRRR/# )r   r_   z%D | Literal[_NoValueSet.NO_VALUE_SET]r   rm   r   )r   s   "r   r   r`      s     
 
<
	
r   c                	    V P                   V ,          #   \         dH    T\        P                  Jd   Tu # T P                  \        P                  Jd   T P                  u #  Mi ; i\        R T P                   R24      h)zRun variable "z!" has no value and no default set)rj   rh   r   r<   rd   LookupErrorrc   ro   s   &&r   rp   rq      s{    	%%%d++ 	%f111f&9&99}}$ :	% TZZL(IJ
 	
s    !A'*A'&A'c                    V ^8  d   QhRRRR/# )r   r@   r   r   rL   r   )r   s   "r   r   r`      s       ~ r   c                	x    V P                   p\        WP                  V \        P                  4      4      pWV &   V# rN   )rj   r   rp   r   r<   )rH   r@   current_varstokens   &&  r   set
RunVar.set   s7    ))D"2"249L9L"MN"Tr   c                    V ^8  d   QhRRRR/# )r   rz   rL   r   r   r   )r   s   "r   r   r`      s      > d r   c                	2   VP                   V Jd   \        R 4      hVP                  '       d   \        R4      hVP                  \        P
                  J d    V P                  V  MVP                  V P                  V &   RVn        R#   \         d     Li ; i)z)This token does not belong to this RunVarz This token has already been usedTN)rE   
ValueErrorrG   rF   r9   r<   rj   rh   )rH   rz   s   &&r   rW   RunVar.reset   s    ::T!HII????@@<<;333&&t, (-||Dt$  s   B BBc                   V ^8  d   QhRR/# )r   r   r^   r   )r   s   "r   r   r`      s     / /# /r   c                	$    R V P                   : R2# )z<RunVar name=>)rc   rO   s   &r   __repr__RunVar.__repr__   s    tzznA..r   )rd   rc   Nrb   )r,   r-   r.   r/   r0   rZ   r9   r<   r1   rI   propertyrj   r   rp   r{   rW   r   r2   r   r   r   r   r   |   s}     $I6A6N6NL3N KW    + +  @L
"/ /r   )r   r   r   r   r"   r%   r5   ))__conditional_annotations__
__future__r   builtins@py_builtins_pytest.assertion.rewrite	assertionrewrite
@pytest_ar__all__r:   dataclassesr   typesr   typingr   r	   r
   r   r   r   weakrefr   _core._eventloopr   abcr   r   r   r   r"   r%   r   r5   r7   r1   Enumr9   r   r   )r   s   @r   <module>r      s    " "      !  B B % / CLCL+	8; 
$U#  $ 4  @Q?R	< R$)) '!* (H/WQZ H/r   