Server : Apache/2.4.62 (Unix) OpenSSL/1.0.2k-fips System : Linux server1.richineiserver.com 3.10.0-1160.119.1.el7.x86_64 #1 SMP Tue Jun 4 14:43:51 UTC 2024 x86_64 User : fdshops ( 1003) PHP Version : 8.2.21 Disable Function : NONE Directory : /lib/python2.7/site-packages/requests_toolbelt/downloadutils/ |
�
ӵ 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