܈hSSKJr SSKrSSKJr SSKJr SSKJr \RS:aSSK J r "SS \ 5r "S S \ 5r"S S \ 5r"SS\ 5r"SS\ 5r"SS\5rS#Sjr"SS\ 5r"SS\ 5r"SS\ 5r"SS\5r"SS\ 5r"SS \5r"S!S"\5rg)$) annotationsN) Generator)dedent)Any) )BaseExceptionGroupc\rSrSrSrSrg)BrokenResourceError z 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 ?D:\TimeStamps\venv\Lib\site-packages\anyio/_core/_exceptions.pyr r rr c\rSrSrSrSrg)BrokenWorkerProcesszq Raised by :meth:`~anyio.to_process.run_sync` if the worker process terminates abruptly or otherwise misbehaves. r Nrr rrrrrrrc@^\rSrSrSrSU4SjjrSU4SjjrSrU=r$)BrokenWorkerInterpreterzn Raised by :meth:`~anyio.to_interpreter.run_sync` if an unexpected exception is raised in the subinterpreter. c8>URnU(dqUR(a7UR(a&URRSUR3nO)URR=(d URn[TU]U5 Xlg)Nz: ) formattedtypemsgrsuper__init__excinfo)selfr$r! __class__s rr# BrokenWorkerInterpreter.__init__ sg||  ../r'++?ll++:w{{  rc>URRn[S[TU]5SUS3R 55$![ a [TU]5s$f=f)Nz z@ Uncaught in the interpreter: )r$ errdisplayrr"__str__strip Exception)r%rr&s rr*BrokenWorkerInterpreter.__str__,su  //I"#$   EG  %7?$ $ %sAA A )r$)r$r)returnstr) rrrrrr#r*r __classcell__r&s@rrrs rrc0^\rSrSrSrSU4SjjrSrU=r$)BusyResourceError=z[ Raised when two tasks are trying to read from or write to the same resource concurrently. c,>[TU]SUS35 g)NzAnother task is already z this resourcer"r#)r%actionr&s rr#BusyResourceError.__init__Cs 3F8>JKrr )r7r/rrrrrr#rr0r1s@rr3r3=s LLrr3c\rSrSrSrSrg)ClosedResourceErrorGz:Raised when trying to use a resource that has been closed.r Nrr rrr;r;GsDrr;c\rSrSrSrSrg)ConnectionFailedKzy Raised when a connection attempt fails. .. note:: This class inherits from :exc:`OSError` for backwards compatibility. r Nrr rrr>r>Ksrr>c## [U[5(a'URHn[U5ShvN M gUv gN7f)N) isinstancer exceptionsiterate_exceptions) exceptionexcs rrCrCSs?)/00''C)#. . .( /s3AAAc0^\rSrSrSrSU4SjjrSrU=r$)DelimiterNotFound]z Raised during :meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_until` if the maximum number of bytes has been read without the delimiter being found. c,>[TU]SUS35 g)Nz,The delimiter was not found among the first z bytesr6)r% max_bytesr&s rr#DelimiterNotFound.__init__ds :9+V L rr )rJintr.Noner9r1s@rrGrG]s   rrGc\rSrSrSrSrg) EndOfStreamjzS Raised when trying to read from a stream that has been closed from the other end. r Nrr rrrOrOjsrrOc0^\rSrSrSrSU4SjjrSrU=r$)IncompleteReadpz 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$>[TU]S5 g)NzBThe stream was closed before the read operation could be completedr6r%r&s rr#IncompleteRead.__init__xs  P rr r.rMr9r1s@rrRrRps  rrRc\rSrSrSrSrg)TypedAttributeLookupError~z Raised by :meth:`~anyio.TypedAttributeProvider.extra` when the given typed attribute is not found and no default value has been given. r Nrr rrrYrY~rrrYc\rSrSrSrSrg) WouldBlockz8Raised by ``X_nowait`` functions if ``X()`` would block.r Nrr rrr\r\sBrr\c\rSrSrSrSrg)NoEventLoopErrorz 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 Nrr rrr_r_rrr_c0^\rSrSrSrSU4SjjrSrU=r$)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$>[TU]S5 g)NzCThe event loop associated with the given token has already finishedr6rUs rr#RunFinishedError.__init__s  Q rr rWr9r1s@rrbrbs   rrb)rD BaseExceptionr.z$Generator[BaseException, None, None]) __future__rsyscollections.abcrtextwraprtypingr version_infoexceptiongroupr r,r rrr3r;OSErrorr>rCrGrOrR LookupErrorrYr\ RuntimeErrorr_rbr rrrqs" %g1)) i FL LE)Ew)   )  Y   CC|  |  r