U
    g                     @  s~   d dl mZ d dlmZmZ d dlmZmZ d dlm	Z	 ddl
mZmZmZmZ ddlmZmZ edd	G d
d deZdS )    )annotations)CallableMapping)	dataclassfield)Any   )ClosedResourceErrorDelimiterNotFoundEndOfStreamIncompleteRead)AnyByteReceiveStreamByteReceiveStreamF)eqc                   @  s   e Zd ZU dZded< ededZded< edddZd	ed
< ddddZ	e
ddddZe
ddddZd!dddddZdddddZddddddZd S )"BufferedByteReceiveStreamz
    Wraps any bytes-based receive stream and uses a buffer to provide sophisticated
    receiving capabilities in the form of a byte stream.
    r   receive_streamF)initdefault_factory	bytearray_buffer)r   defaultbool_closedNone)returnc                   s   | j  I d H  d| _d S )NT)r   acloser   self r   :/tmp/pip-unpacked-wheel-3u0cc9gf/anyio/streams/buffered.pyr      s    z BufferedByteReceiveStream.aclosebytesc                 C  s
   t | jS )z"The bytes currently in the buffer.)r    r   r   r   r   r   buffer   s    z BufferedByteReceiveStream.bufferzMapping[Any, Callable[[], Any]]c                 C  s   | j jS N)r   extra_attributesr   r   r   r   r#      s    z*BufferedByteReceiveStream.extra_attributes   int)	max_bytesr   c                   s   | j r
t| jr2t| jd | }| jd |= |S t| jtrP| j|I d H S | j I d H }t||kr| j	||d   |d | S |S d S r"   )
r   r	   r   r    
isinstancer   r   receivelenextend)r   r&   chunkr   r   r   r(   #   s    z!BufferedByteReceiveStream.receive)nbytesr   c              
     s   |t | j }|dkr8| jd| }| jd|= t|S z4t| jtrZ| j|I dH }n| j I dH }W n( tk
r } z
t|W 5 d}~X Y nX | j	| q dS )a-  
        Read exactly the given amount of bytes from the stream.

        :param nbytes: the number of bytes to read
        :return: the bytes read
        :raises ~anyio.IncompleteRead: if the stream was closed before the requested
            amount of bytes could be read from the stream

        r   N)
r)   r   r    r'   r   r   r(   r   r   r*   )r   r,   	remainingretvalr+   excr   r   r   receive_exactly8   s    z)BufferedByteReceiveStream.receive_exactly)	delimiterr&   r   c           	   
     s   t |}d}| j||}|dkrL| jd| }| jd|t | = t|S t | j|krbt|z| j I dH }W n( tk
r } z
t|W 5 d}~X Y nX t	t | j| d d}| j
| qdS )aM  
        Read from the stream until the delimiter is found or max_bytes have been read.

        :param delimiter: the marker to look for in the stream
        :param max_bytes: maximum number of bytes that will be read before raising
            :exc:`~anyio.DelimiterNotFound`
        :return: the bytes read (not including the delimiter)
        :raises ~anyio.IncompleteRead: if the stream was closed before the delimiter
            was found
        :raises ~anyio.DelimiterNotFound: if the delimiter is not found within the
            bytes read up to the maximum allowed

        r   N   )r)   r   findr    r
   r   r(   r   r   maxr*   )	r   r1   r&   Zdelimiter_sizeoffsetindexfounddatar/   r   r   r   receive_untilS   s    z'BufferedByteReceiveStream.receive_untilN)r$   )__name__
__module____qualname____doc____annotations__r   r   r   r   r   propertyr!   r#   r(   r0   r9   r   r   r   r   r      s   
r   N)
__future__r   collections.abcr   r   Zdataclassesr   r   typingr    r	   r
   r   r   abcr   r   r   r   r   r   r   <module>   s   