�
E�g� � � � 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 �h/home/asafur/pinokio/api/open-webui.git/app/env/lib/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 �4 � e Zd Zdeddfd�Zd
dededefd �ZdS ) �StreamWrapperPayloadr r Nc � �@ K � | � |� � � d {V �� d S r ��_valuer s r �writezStreamWrapperPayload.writeA �0 � � � ��k�k�&�!�!�!�!�!�!�!�!�!�!�!r �utf-8�strict�encoding�errorsc � � t d� � �)NzUnable to decode.)� TypeError)r r5 r6 s r �decodezStreamWrapperPayload.decodeD s � ��+�,�,�,r )r3 r4 )r r r! r r1 r" r9 r# r r r- r- ? se � � � � � �"�"6� "�4� "� "� "� "�-� -�s� -�c� -�� -� -� -� -� -� -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 r< r r � __class__s �r r zStreamPayload.__init__J 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.writeM r2 r )r r r! r r r r1 �
__classcell__)r? s @r r; r; H s| �� � � � � �3�c� 3�#� 3�� 3�� 3� 3� 3� 3� 3� 3�"�"6� "�4� "� "� "� "� "� "� "� "r r; )�__doc__r r( �typingr r r r r �abcr �payloadr
r �__all__r r r- r; r# r r �<module>rG 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