+
    P\i7  c                  s   ^ RI Ht ^ RIt^ RIHt ^ RIHt ^ RIHt ]P                  R#8  d   ^ RI
Ht  ! R R]4      t ! R	 R
]4      t ! R R]4      t ! R R]4      t ! R R]4      t ! R R]4      tR R lt ! R R]4      t ! R R]4      t ! R R]4      t ! R R]4      t ! R R]4      t ! R R ]4      t ! R! R"]4      tR# )$i    )annotationsN)	Generator)dedent)Any)BaseExceptionGroupc                  s    ] tR t^tRtRtR# )BrokenResourceErrorz
Raised when trying to use a resource that has been rendered unusable due to external
causes (e.g. a send stream whose peer has disconnected).
 N__name__
__module____qualname____firstlineno____doc____static_attributes__r       </usr/lib/python3.14/site-packages/anyio/_core/_exceptions.pyr   r          r   r   c                  s    ] tR t^tRtRtR# )BrokenWorkerProcesszq
Raised by :meth:`~anyio.to_process.run_sync` if the worker process terminates abruptly or
otherwise misbehaves.
r   Nr   r   r   r   r   r      r   r   r   c                  sD   a  ] tR t^tRtR V 3R lltR V 3R lltRtV ;t# )BrokenWorkerInterpreterzn
Raised by :meth:`~anyio.to_interpreter.run_sync` if an unexpected exception is
raised in the subinterpreter.
c                   V ^8  d   QhRR/# )   excinfor   r   Zformat   "r   __annotate__$BrokenWorkerInterpreter.__annotate__    s     
 
 
r   c                	sB  < VP                   pV'       gu   VP                  '       d9   VP                  '       d'   VP                  P                   R VP                   2pM*VP                  P                  ;'       g    VP                  p\        SV `  V4       Wn        R# )z: N)	formattedZtypemsgr   super__init__r   )selfr   r   	__class__s   && r   r   Z BrokenWorkerInterpreter.__init__    sn    ||| ../r'++?ll++::w{{r   c               r   )r   returnstrr   r   r   r   r   r   ,   s       r   c                	s   <  V P                   P                  p\        R \        SV `  4        RV R 2P                  4       4      #   \         d    \        ST `  4       u # i ; i)z
                z@

                Uncaught in the interpreter:

                )r   Z
errdisplayr   r   __str__Zstrip	Exception)r   r   r   s   & r   r"   ZBrokenWorkerInterpreter.__str__,   su    	//I "# $   EG   	%7?$$	%s   A A! A!)r   )	r   r	   r
   r   r   r   r"   r   __classcell__r      @r   r   r      s    

 
 r   r   c                  s2   a  ] tR t^=tRtR V 3R lltRtV ;t# )BusyResourceErrorz[
Raised when two tasks are trying to read from or write to the same resource
concurrently.
c               r   )r   actionr!   r   r   r   r   r   ZBusyResourceError.__annotate__C   s     L Ls Lr   c                	.   < \         SV `  R V R24       R# )zAnother task is already z this resourceNr   r   )r   r(   r      &&r   r   ZBusyResourceError.__init__C   s    3F8>JKr   r   r   r	   r
   r   r   r   r   r$   r%   r&   r   r'   r'   =   s    
L Lr   r'   c                  s    ] tR t^GtRtRtR# )ClosedResourceErrorz:Raised when trying to use a resource that has been closed.r   Nr   r   r   r   r-   r-   G   s    Dr   r-   c                  s    ] tR t^KtRtRtR# )ConnectionFailedzy
Raised when a connection attempt fails.

.. note:: This class inherits from :exc:`OSError` for backwards compatibility.
r   Nr   r   r   r   r.   r.   K   s    r   r.   c                    V ^8  d   QhRRRR/# )r   	exceptionZBaseExceptionr    z$Generator[BaseException, None, None]r   r   r   r   r   r   S   s      )r   c              #  s   "   \        V \        4      '       d)   V P                   F  p\        V4       R j  xL
  K  	  R # V x  R #  L5i)N)Z
isinstancer   Z
exceptionsiterate_exceptions)r0   Zexcs   & r   r1   r1   S   s?      )/00''C)#... (  /s   4A	AA	c                  s2   a  ] tR t^]tRtR V 3R lltRtV ;t# )DelimiterNotFoundz
Raised during
:meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_until` if the
maximum number of bytes has been read without the delimiter being found.
c               r/   )r   	max_bytesZintr    Noner   r   r   r   r   ZDelimiterNotFound.__annotate__d   s     
 
# 
$ 
r   c                	r)   )z,The delimiter was not found among the first z bytesNr*   )r   r3   r   r+   r   r   ZDelimiterNotFound.__init__d   s    :9+VL	
r   r   r,   r%   r&   r   r2   r2   ]   s    
 
r   r2   c                  s    ] tR t^jtRtRtR# )EndOfStreamzS
Raised when trying to read from a stream that has been closed from the other end.
r   Nr   r   r   r   r5   r5   j   s    r   r5   c                  s2   a  ] tR t^ptRtR V 3R lltRtV ;t# )IncompleteReadz
Raised during
:meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_exactly` or
:meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_until` if the
connection is closed before the requested amount of bytes has been read.
c               r   r   r    r4   r   r   r   r   r   ZIncompleteRead.__annotate__x        
 
$ 
r   c                	&   < \         SV `  R 4       R# )zBThe stream was closed before the read operation could be completedNr*   r   r      &r   r   ZIncompleteRead.__init__x   s    P	
r   r   r,   r%   r&   r   r6   r6   p   s    
 
r   r6   c                  s    ] tR t^~tRtRtR# )TypedAttributeLookupErrorz
Raised by :meth:`~anyio.TypedAttributeProvider.extra` when the given typed attribute
is not found and no default value has been given.
r   Nr   r   r   r   r<   r<   ~   r   r   r<   c                  s    ] tR t^tRtRtR# )
WouldBlockz8Raised by ``X_nowait`` functions if ``X()`` would block.r   Nr   r   r   r   r=   r=      s    Br   r=   c                  s    ] tR t^tRtRtR# )NoEventLoopErrora  
Raised by several functions that require an event loop to be running in the current
thread when there is no running event loop.

This is also raised by :func:`.from_thread.run` and :func:`.from_thread.run_sync`
if not calling from an AnyIO worker thread, and no ``token`` was passed.
r   Nr   r   r   r   r>   r>      s    r   r>   c                  s2   a  ] tR t^tRtR V 3R lltRtV ;t# )RunFinishedErrorz
Raised by :func:`.from_thread.run` and :func:`.from_thread.run_sync` if the event
loop associated with the explicitly passed token has already finished.
c               r   r7   r   r   r   r   r   ZRunFinishedError.__annotate__   r8   r   c                	r9   )zCThe event loop associated with the given token has already finishedNr*   r:   r;   r   r   ZRunFinishedError.__init__   s    Q	
r   r   r,   r%   r&   r   r?   r?      s    

 
r   r?   )i   i   )Z
__future__r    ZsysZcollections.abcr   Ztextwrapr   Ztypingr   Zversion_infoZexceptiongroupr   r#   r   r   r   r'   r-   ZOSErrorr.   r1   r2   r5   r6   ZLookupErrorr<   r=   ZRuntimeErrorr>   r?   r   r   r   <module>r@      s    " 
 %  g1) )  i  FL	 LE) Ew 

	 

) 
Y 
 C C| 	
| 	
r   