o :ήcX @sddlmZddlmZGdddeZGdddeZGdddeZGd d d eZGd d d eZ Gd ddeZ Gddde Z GdddeZ GdddeZGdddeZdS))format_exception)Listc@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__r r >/tmp/pip-target-vg8gfxp4/lib/python/anyio/_core/_exceptions.pyrrc@r)BrokenWorkerProcesszv Raised by :func:`run_sync_in_process` if the worker process terminates abruptly or otherwise misbehaves. Nrr r r r r r rcs&eZdZdZdeffdd ZZS)BusyResourceErrorzYRaised when two tasks are trying to read from or write to the same resource concurrently.actionctd|ddS)NzAnother task is already z this resourcesuper__init__)selfr __class__r r rszBusyResourceError.__init__)rrr r strr __classcell__r r rr rsrc@r)ClosedResourceErrorz:Raised when trying to use a resource that has been closed.Nrr r r r rr rcs*eZdZdZdeddffdd 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_bytesreturnNcr)Nz,The delimiter was not found among the first z bytesr)rrrr r r$s zDelimiterNotFound.__init__)rrr r intrrr r rr rsrc@r) EndOfStreamzQRaised when trying to read from a stream that has been closed from the other end.Nrr r r r r*r rc@s>eZdZUdZdZeeed<defddZ defddZ d S) ExceptionGroupz Raised when multiple exceptions have been raised in a task group. :var ~typing.Sequence[BaseException] exceptions: the sequence of exceptions raised together z---------------------------- exceptionsrcCs2dd|jD}t|jd|j|j|S)NcSs$g|]}dtt|||jqS))joinrtype __traceback__.0excr r r :sz*ExceptionGroup.__str__..z+ exceptions were raised in the task group: )r!len SEPARATORr#)r tracebacksr r r __str__9s  zExceptionGroup.__str__cCs,ddd|jD}d|jjd|dS)Nz, css|]}t|VqdS)N)reprr&r r r Dsz*ExceptionGroup.__repr__..)r#r!rr)rexception_reprsr r r __repr__CszExceptionGroup.__repr__N) rrr r r+r BaseException__annotations__rr-r3r r r r r .s   r cs"eZdZdZdfdd ZZS)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. rNcstddS)NzBThe stream was closed before the read operation could be completedr)rrr r rOszIncompleteRead.__init__)rN)rrr r rrr r rr r6Hsr6c@r)TypedAttributeLookupErrorz Raised by :meth:`~anyio.TypedAttributeProvider.extra` when the given typed attribute is not found and no default value has been given. Nrr r r r r7Ur r7c@r) WouldBlockz8Raised by ``X_nowait`` functions if ``X()`` would block.Nrr r r r r8\r r8N) tracebackrtypingr Exceptionrrrrrrr4r r6 LookupErrorr7r8r r r r s