o ;'h @sddlmZddlZddlmZddlmZddlmZej dkr'ddl m Z Gdd d e Z Gd d d e ZGd d d e ZGddde ZGddde ZGddde ZGddde ZGddde ZGdddeZGddde Zd"d d!ZdS)#) annotationsN) Generator)dedent)Any) )BaseExceptionGroupc@eZdZdZdS)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____doc__rrMC:\Users\shubh\Videos\agent\nova\Lib\site-packages\anyio/_core/_exceptions.pyr r c@r )BrokenWorkerProcessz} Raised by :meth:`~anyio.to_process.run_sync` if the worker process terminates abruptly or otherwise misbehaves. Nr rrrrrrrcs0eZdZdZd fdd Zd fdd ZZS) BrokenWorkerIntepreterzz Raised by :meth:`~anyio.to_interpreter.run_sync` if an unexpected exception is raised in the subinterpreter. excinforcsP|j}|s|jr|jr|jjd|j}n|jjp|j}t|||_dS)Nz: ) formattedtypemsgr super__init__r)selfrr __class__rrr s   zBrokenWorkerIntepreter.__init__returnstrcsJz|jj}WntytYSwtdtd|dS)Nz z@ Uncaught in the interpreter: )rZ errdisplay Exceptionr__str__rstrip)rrrrrr!,s  zBrokenWorkerIntepreter.__str__)rr)rr)r r rrrr! __classcell__rrrrrs rc"eZdZdZdfdd ZZS)BusyResourceErrorzg Raised when two tasks are trying to read from or write to the same resource concurrently. actionrctd|ddS)NzAnother task is already z this resourcerr)rr&rrrrCszBusyResourceError.__init__)r&rr r rrrr#rrrrr%=sr%c@r )ClosedResourceErrorz:Raised when trying to use a resource that has been closed.Nr rrrrr*Grr*cs"eZdZdZdfdd ZZS) DelimiterNotFoundz Raised during :meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_until` if the maximum number of bytes has been read without the delimiter being found. max_bytesintrNonecr')Nz,The delimiter was not found among the first z bytesr()rr,rrrrRs zDelimiterNotFound.__init__)r,r-rr.r)rrrrr+Ksr+c@r ) EndOfStreamz[ Raised when trying to read from a stream that has been closed from the other end. Nr rrrrr/Xrr/cr$)IncompleteReada 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. rr.cstddS)NzBThe stream was closed before the read operation could be completedr()rrrrrfszIncompleteRead.__init__)rr.r)rrrrr0^sr0c@r )TypedAttributeLookupErrorz Raised by :meth:`~anyio.TypedAttributeProvider.extra` when the given typed attribute is not found and no default value has been given. Nr rrrrr1lrr1c@r ) WouldBlockz8Raised by ``X_nowait`` functions if ``X()`` would block.Nr rrrrr2srr2 exception BaseExceptionr$Generator[BaseException, None, None]ccs4t|tr|jD] }t|EdHq dS|VdS)N) isinstancer exceptionsiterate_exceptions)r3excrrrr8ws    r8)r3r4rr5) __future__rsyscollections.abcrtextwraprtypingr version_infoZexceptiongrouprr r rrr%r*r+r/r0 LookupErrorr1r2r8rrrrs$      #