U Rh @sddlmZddlZddlmZejdkr6ddlmZGdddeZ Gdd d eZ Gd d d eZ Gd d d eZ GdddeZ GdddeZGdddeZGdddeZGdddeZdddddZdS)) annotationsN) Generator) )BaseExceptionGroupc@seZdZdZdS)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 =./venv/lib/python3.8/site-packages/anyio/_core/_exceptions.pyr src@seZdZdZdS)BrokenWorkerProcesszv Raised by :func:`run_sync_in_process` if the worker process terminates abruptly or otherwise misbehaves. Nrr r r rrsrcs&eZdZdZddfdd ZZS)BusyResourceErrorzg Raised when two tasks are trying to read from or write to the same resource concurrently. str)actioncstd|ddS)NzAnother task is already z this resourcesuper__init__)selfr __class__r rrszBusyResourceError.__init__r r r r r __classcell__r r rrrsrc@seZdZdZdS)ClosedResourceErrorz:Raised when trying to use a resource that has been closed.Nrr r r rr"srcs(eZdZdZdddfdd 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. intNone) max_bytesreturncstd|ddS)Nz,The delimiter was not found among the first z bytesr)rrrr rr-s zDelimiterNotFound.__init__rr r rrr&src@seZdZdZdS) EndOfStreamz[ Raised when trying to read from a stream that has been closed from the other end. Nrr r r rr!3sr!cs&eZdZdZddfdd 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. r)r cstddS)NzBThe stream was closed before the read operation could be completedr)rrr rrAszIncompleteRead.__init__rr r rrr"9sr"c@seZdZdZdS)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 rr#Gsr#c@seZdZdZdS) WouldBlockz8Raised by ``X_nowait`` functions if ``X()`` would block.Nrr r r rr$Nsr$ BaseExceptionz$Generator[BaseException, None, None]) exceptionr ccs0t|tr&|jD]}t|EdHqn|VdS)N) isinstancer exceptionsiterate_exceptions)r&excr r rr)Rs  r))Z __future__rsysZcollections.abcr version_infoZexceptiongroupr Exceptionrrrrrr!r" LookupErrorr#r$r)r r r rs