ruạṛ
a [��fS � @ s. d Z ddlZdd� ZG dd� dej�ZeZdS )z Utilities for the Request class.� Nc s � fdd�}t |�S )a Create a read-only header property. Args: wsgi_name (str): Case-sensitive name of the header as it would appear in the WSGI environ ``dict`` (i.e., 'HTTP_*') Returns: A property instance than can be assigned to a class variable. c s* z| j � pd W S ty$ Y d S 0 d S �N)�env�KeyError��self�� wsgi_name� �z/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/falcon/request_helpers.py�fget s z header_property.<locals>.fget)�property)r r r r r �header_property s r c @ sr e Zd ZdZdd� Zdd� Zdd� ZeZdd � Zd d � Z d d � Z dd� Z ddd�Z ddd�Z ddd�Zdd� ZdS ) � BoundedStreama� Wrap *wsgi.input* streams to make them more robust. ``socket._fileobject`` and ``io.BufferedReader`` are sometimes used to implement *wsgi.input*. However, app developers are often burned by the fact that the `read()` method for these objects block indefinitely if either no size is passed, or a size greater than the request's content length is passed to the method. This class normalizes *wsgi.input* behavior between WSGI servers by implementing non-blocking behavior for the cases mentioned above. Args: stream: Instance of ``socket._fileobject`` from ``environ['wsgi.input']`` stream_len: Expected content length of the stream. c C s || _ || _| j| _d S r )�stream� stream_len�_bytes_remaining)r r r r r r �__init__= s zBoundedStream.__init__c C s | S r r r r r r �__iter__C s zBoundedStream.__iter__c C s t | j�S r )�nextr r r r r �__next__F s zBoundedStream.__next__c C s6 |du s|dks|| j kr | j }| j |8 _ ||�S )ay Helper function for proxing reads to the underlying stream. Args: size (int): Maximum number of bytes to read. Will be coerced, if None or -1, to the number of remaining bytes in the stream. Will likewise be coerced if greater than the number of remaining bytes, to avoid making a blocking call to the wrapped stream. target (callable): Once `size` has been fixed up, this function will be called to actually do the work. Returns: bytes: Data read from the stream, as returned by `target`. N���)r )r �size�targetr r r �_readK s zBoundedStream._readc C s dS )zAlways returns ``True``.Tr r r r r �readablee s zBoundedStream.readablec C s dS �zAlways returns ``False``.Fr r r r r �seekablei s zBoundedStream.seekablec C s dS r r r r r r � writeablem s zBoundedStream.writeableNc C s | � || jj�S )z�Read from the stream. Args: size (int): Maximum number of bytes/characters to read. Defaults to reading until EOF. Returns: bytes: Data read from the stream. )r r �read)r r r r r r q s zBoundedStream.readc C s | � || jj�S )z�Read a line from the stream. Args: limit (int): Maximum number of bytes/characters to read. Defaults to reading until EOF. Returns: bytes: Data read from the stream. )r r �readline)r �limitr r r r s zBoundedStream.readlinec C s | � || jj�S )z�Read lines from the stream. Args: hint (int): Maximum number of bytes/characters to read. Defaults to reading until EOF. Returns: bytes: Data read from the stream. )r r � readlines)r �hintr r r r! � s zBoundedStream.readlinesc C s t d��dS )z0Always raises IOError; writing is not supported.zStream is not writeableN)�IOError)r �datar r r �write� s zBoundedStream.write)N)N)N)�__name__� __module__� __qualname__�__doc__r r r r r r r r r r r! r% r r r r r ) s r )r) �ior �IOBaser �Bodyr r r r �<module> s y
cải xoăn