hddlmZddlZddlmZddlmZddlmZejdkrddl m Z Gdd e Z Gd d e ZGd d e ZGdde ZGdde ZGddeZ d#dZGdde ZGdde ZGdde ZGddeZGdde ZGdd eZGd!d"eZy)$) annotationsN) Generator)dedent)Any) )BaseExceptionGroupceZdZdZy)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__JKr)r/r(r rrrrr)r*s@rr,r,=s LLrr,ceZdZdZy)ClosedResourceErrorz:Raised when trying to use a resource that has been closed.Nr rrrr2r2GsDrr2ceZdZdZy)ConnectionFailedz Raised when a connection attempt fails. .. note:: This class inherits from :exc:`OSError` for backwards compatibility. Nr rrrr4r4Ksrr4c#Kt|tr%|jD]}t|Ed{y|y7 w)N) isinstancer exceptionsiterate_exceptions) exceptionexcs rr8r8Ss=)/0''C)#. . .( /s .?= ?c$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. c,t|d|dy)Nz,The delimiter was not found among the first z bytesr.)r max_bytesr!s rrzDelimiterNotFound.__init__ds :9+V L r)r>intr'Noner0r*s@rr<r<]s   rr<ceZdZdZy) EndOfStreamz[ Raised when trying to read from a stream that has been closed from the other end. Nr rrrrBrBjsrrBc$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. c$t|dy)NzBThe stream was closed before the read operation could be completedr.r r!s rrzIncompleteRead.__init__xs  P rr'r@r0r*s@rrDrDps  rrDceZdZdZy)TypedAttributeLookupErrorz Raised by :meth:`~anyio.TypedAttributeProvider.extra` when the given typed attribute is not found and no default value has been given. Nr rrrrIrI~rrrIceZdZdZy) WouldBlockz8Raised by ``X_nowait`` functions if ``X()`` would block.Nr rrrrKrKsBrrKceZdZdZy)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. Nr rrrrMrMrrrMc$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. c$t|dy)NzCThe event loop associated with the given token has already finishedr.rFs rrzRunFinishedError.__init__s  Q rrGr0r*s@rrOrOs   rrO)r9 BaseExceptionr'z$Generator[BaseException, None, None]) __future__rsyscollections.abcrtextwraprtypingr version_infoexceptiongroupr r&r rrr,r2OSErrorr4r8r<rBrD LookupErrorrIrK RuntimeErrorrMrOrrrr\s" %g1)) i FL LE)Ew)   )  Y   CC|  |  r