관리-도구
편집 파일: payload_streamer.cpython-311.pyc
� �܋f' � � � d Z ddlZddlZddlmZmZmZmZmZ ddl m Z ddl m Z m Z dZ G d� d � � Z G d � d � � Z e e� � G d � d e � � � � Z e e� � G d� de� � � � ZdS )am Payload implementation for coroutines as data provider. As a simple case, you can upload data from file:: @aiohttp.streamer async def file_sender(writer, file_name=None): with open(file_name, 'rb') as f: chunk = f.read(2**16) while chunk: await writer.write(chunk) chunk = f.read(2**16) Then you can use `file_sender` like this: async with session.post('http://httpbin.org/post', data=file_sender(file_name='huge_file')) as resp: print(await resp.text()) ..note:: Coroutine must accept `writer` as first argument � N)�Any� Awaitable�Callable�Dict�Tuple� )�AbstractStreamWriter)�Payload� payload_type)�streamerc �r � e Zd Zdeded f deedf deeef ddfd�Z de ddfd �Z dS ) �_stream_wrapper�coro.N�args�kwargs�returnc �T � t j |� � | _ || _ || _ d S �N)�types� coroutiner r r )�selfr r r s �O/opt/cloudlinux/venv/lib64/python3.11/site-packages/aiohttp/payload_streamer.py�__init__z_stream_wrapper.__init__$ s' � � �O�D�)�)�� ��� � �� � � � �writerc � �L K � | j |g| j �R i | j ��� d {V �� d S r )r r r �r r s r �__call__z_stream_wrapper.__call__. sD � � � ��d�i��:���:�:�:�d�k�:�:�:�:�:�:�:�:�:�:�:r ) �__name__� __module__� __qualname__r r r r r �strr r r � r r r r # s� � � � � � � ��s�I�d�O�+�,� � �C��H�o� � �S�#�X�� � � � � � �;�%9� ;�d� ;� ;� ;� ;� ;� ;r r c �N � e Zd Zdeded f ddfd�Zdededefd�ZdS ) r r .Nr c �L � t j dt d�� � || _ d S )Nz5@streamer is deprecated, use async generators instead� )� stacklevel)�warnings�warn�DeprecationWarningr )r r s r r zstreamer.__init__3 s1 � �� � C� �� � � � � �� � � r r r c �. � t | j ||� � S r )r r )r r r s r r zstreamer.__call__; s � � �t�y�$��7�7�7r ) r r r! r r r r r r r# r r r r 2 sm � � � � � ��X�c�9�T�?�&:� ;� �� � � � �8�c� 8�S� 8�_� 8� 8� 8� 8� 8� 8r r c � � e Zd Zdeddfd�ZdS )�StreamWrapperPayloadr r Nc � �@ K � | � |� � � d {V �� d S r ��_valuer s r �writezStreamWrapperPayload.writeA �0 � � � ��k�k�&�!�!�!�!�!�!�!�!�!�!�!r )r r r! r r1 r# r r r- r- ? s7 � � � � � �"�"6� "�4� "� "� "� "� "� "r r- c �@ � � e Zd Zdedededdf� fd� Zdeddfd�Z� xZS ) � StreamPayload�valuer r r Nc �R �� t � � j |� � g|�R i |�� d S r )�superr )r r5 r r � __class__s �r r zStreamPayload.__init__G s6 �� ����������2�4�2�2�2�6�2�2�2�2�2r r c � �@ K � | � |� � � d {V �� d S r r/ r s r r1 zStreamPayload.writeJ r2 r )r r r! r r r r1 � __classcell__)r8 s @r r4 r4 E s| �� � � � � �3�c� 3�#� 3�� 3�� 3� 3� 3� 3� 3� 3�"�"6� "�4� "� "� "� "� "� "� "� "r r4 )�__doc__r r( �typingr r r r r �abcr �payloadr r �__all__r r r- r4 r# r r �<module>r@ sY ��� �0 � � � � ���� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� %� %� %� %� %� %� *� *� *� *� *� *� *� *� �� ;� ;� ;� ;� ;� ;� ;� ;� 8� 8� 8� 8� 8� 8� 8� 8� � �o� � �"� "� "� "� "�7� "� "� � �"� � �h���"� "� "� "� "�(� "� "� ��"� "� "r