fj7ddlmZddlZddlmZddlmZddlmZej dkrddl m Z Gdd e Z Gd d e ZGd d e ZGdde ZGdde ZGddeZd'dZGdde ZGdde ZGdde ZGdd eZGd!d"e ZGd#d$eZGd%d&eZdS)() annotationsN) Generator)dedent)Any) )BaseExceptionGroupceZdZdZdS)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__kC:\Users\Terasoftware\OneDrive\Desktop\faahhh\fyndo\fyndo\venv\Lib\site-packages\anyio/_core/_exceptions.pyr r rr ceZdZdZdS)BrokenWorkerProcessz} Raised by :meth:`~anyio.to_process.run_sync` if the worker process terminates abruptly or otherwise misbehaves. Nr rrrrrrrrc0eZdZdZdfd Zd fd ZxZS) BrokenWorkerInterpreterzz Raised by :meth:`~anyio.to_interpreter.run_sync` if an unexpected exception is raised in the subinterpreter. excinforc|j}|s8|jr|jr|jjd|j}n|jjp|j}t |||_dS)Nz: ) formattedtypemsgr super__init__r)selfrr __class__s rrz BrokenWorkerInterpreter.__init__ sv ;| ;  ; .??'+??l+:w{  rreturnstrc  |jj}tdtd|dS#t $r#tcYSwxYw)Nz z@ Uncaught in the interpreter: )r errdisplayrr__str__strip Exception)r rr!s rr&zBrokenWorkerInterpreter.__str__,s  /I""   EGG  % % %77??$$ $ $ $ %s A*BB)rr)r"r#)r rrrrr& __classcell__r!s@rrrse      rrc$eZdZdZdfd ZxZS)BusyResourceErrorzg Raised when two tasks are trying to read from or write to the same resource concurrently. actionr#cRtd|ddS)NzAnother task is already z this resourcerr)r r-r!s rrzBusyResourceError.__init__Cs- JFJJJKKKKKr)r-r#r rrrrr)r*s@rr,r,=sQ LLLLLLLLLLrr,ceZdZdZdS)ClosedResourceErrorz:Raised when trying to use a resource that has been closed.Nr rrrr2r2GsDDDDrr2ceZdZdZdS)ConnectionFailedz Raised when a connection attempt fails. .. note:: This class inherits from :exc:`OSError` for backwards compatibility. Nr rrrr4r4Ksrr4 exception BaseExceptionr"$Generator[BaseException, None, None]c#~Kt|tr!|jD]}t|Ed{VdS|VdS)N) isinstancer exceptionsiterate_exceptions)r5excs rr;r;Ssi)/00' / /C)#.. . . . . . . . . / /rc$eZdZdZdfd ZxZS)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_bytesintr"NonecRtd|ddS)Nz,The delimiter was not found among the first z bytesr/)r r?r!s rrzDelimiterNotFound.__init__ds7  L9 L L L     r)r?r@r"rAr0r*s@rr>r>]sG           rr>ceZdZdZdS) EndOfStreamz[ Raised when trying to read from a stream that has been closed from the other end. Nr rrrrDrDjsrrDc$eZdZdZdfd ZxZS)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. r"rAcJtddS)NzBThe stream was closed before the read operation could be completedr/r r!s rrzIncompleteRead.__init__xs,  P     rr"rAr0r*s@rrFrFpsG          rrFceZdZdZdS)TypedAttributeLookupErrorz Raised by :meth:`~anyio.TypedAttributeProvider.extra` when the given typed attribute is not found and no default value has been given. Nr rrrrKrK~rrrKceZdZdZdS) WouldBlockz8Raised by ``X_nowait`` functions if ``X()`` would block.Nr rrrrMrMsBBBBrrMceZdZdZdS)NoEventLoopErrora1 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. Nr rrrrOrOsrrOc$eZdZdZdfd ZxZS)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. r"rAcJtddS)NzCThe event loop associated with the given token has already finishedr/rHs rrzRunFinishedError.__init__s,  Q     rrIr0r*s@rrQrQsG           rrQ)r5r6r"r7) __future__rsyscollections.abcrtextwraprtypingr version_infoexceptiongroupr r(r rrr,r2OSErrorr4r;r>rDrF LookupErrorrKrM RuntimeErrorrOrQrrrr]s"""""" %%%%%%g2111111))     i   FLLLLL LLLEEEEE)EEEw         )      Y     CCCCCCCC|      |      r