golden hour
/lib/python2.7/site-packages/requests_toolbelt/downloadutils
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.py
0 B
Del
OK
__init__.pyc
163 B
Del
OK
__init__.pyo
163 B
Del
OK
stream.py
5.93 KB
Del
OK
stream.pyc
6.01 KB
Del
OK
stream.pyo
6.01 KB
Del
OK
tee.py
4.26 KB
Del
OK
tee.pyc
4.4 KB
Del
OK
tee.pyo
4.4 KB
Del
OK
Edit: tee.pyc
� ӵ Yc @ sa d Z d d l Z d Z d d d g Z d � Z e d d � Z e d d � Z e d d � Z d S( s Tee function implementations.i����Ni t teet tee_to_filet tee_to_bytearrayc c s9 x2 | j j d | d | � D] } | | � | Vq Wd S( Nt amtt decode_content( t rawt stream( t responset callbackt chunksizeR t chunk( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/downloadutils/tee.pyt _tee s c C sO d t | d d � k p' t | t j � s9 t d � � n t | | j | | � S( s" Stream the response both to the generator and a file. This will stream the response body while writing the bytes to ``fileobject``. Example usage: .. code-block:: python resp = requests.get(url, stream=True) with open('save_file', 'wb') as save_file: for chunk in tee(resp, save_file): # do stuff with chunk .. code-block:: python import io resp = requests.get(url, stream=True) fileobject = io.BytesIO() for chunk in tee(resp, fileobject): # do stuff with chunk :param response: Response from requests. :type response: requests.Response :param fileobject: Writable file-like object. :type fileobject: file, io.BytesIO :param int chunksize: (optional), Size of chunk to attempt to stream. :param bool decode_content: (optional), If True, this will decode the compressed content of the response. :raises: TypeError if the fileobject wasn't opened with the right mode or isn't a BytesIO object. t bt modet s� tee() will write bytes directly to this fileobject, it must be opened with the "b" flag if it is a file or inherit from io.BytesIO.( t getattrt isinstancet iot BytesIOt TypeErrorR t write( R t fileobjectR R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/downloadutils/tee.pyR s (c c sA t | d � �, } x" t | | | | � D] } | Vq( WWd QXd S( s� Stream the response both to the generator and a file. This will open a file named ``filename`` and stream the response body while writing the bytes to the opened file object. Example usage: .. code-block:: python resp = requests.get(url, stream=True) for chunk in tee_to_file(resp, 'save_file'): # do stuff with chunk :param response: Response from requests. :type response: requests.Response :param str filename: Name of file in which we write the response content. :param int chunksize: (optional), Size of chunk to attempt to stream. :param bool decode_content: (optional), If True, this will decode the compressed content of the response. t wbN( t openR ( R t filenameR R t fdR ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/downloadutils/tee.pyR A s c C s4 t | t � s t d � � n t | | j | | � S( sx Stream the response both to the generator and a bytearray. This will stream the response provided to the function, add them to the provided :class:`bytearray` and yield them to the user. .. note:: This uses the :meth:`bytearray.extend` by default instead of passing the bytearray into the ``readinto`` method. Example usage: .. code-block:: python b = bytearray() resp = requests.get(url, stream=True) for chunk in tee_to_bytearray(resp, b): # do stuff with chunk :param response: Response from requests. :type response: requests.Response :param bytearray bytearr: Array to add the streamed bytes to. :param int chunksize: (optional), Size of chunk to attempt to stream. :param bool decode_content: (optional), If True, this will decode the compressed content of the response. s4 tee_to_bytearray() expects bytearr to be a bytearray( R t bytearrayR R t extend( R t bytearrR R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/downloadutils/tee.pyR \ s ( t __doc__R t _DEFAULT_CHUNKSIZEt __all__R t NoneR R R ( ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/downloadutils/tee.pyt <module> s 0
Save