codekingpro/portable-devtools
115k
1�
2 ��j� � �� � S r SSKrSSKrSSKJrJrJrJrJr SSK J3r4 SSK J r J
r
Sr " S S 5 r " S5 S 5 r\
" \5 " S S
\ 5 5 r\
" \5 " S S\5 5 rg)am 6Payload implementation for coroutines as data provider.7 8As a simple case, you can upload data from file::9 10 @aiohttp.streamer11 async def file_sender(writer, file_name=None):12 with open(file_name, 'rb') as f:13 chunk = f.read(2**16)14 while chunk:15 await writer.write(chunk)16 17 chunk = f.read(2**16)18 19Then you can use `file_sender` like this:20 21 async with session.post('http://httpbin.org/post',22 data=file_sender(file_name='huge_file')) as resp:23 print(await resp.text())24 25..note:: Coroutine must accept `writer` as first argument26 27� N)�Any� Awaitable�Callable�Dict�Tuple� )�AbstractStreamWriter)�Payload� payload_type)�streamerc �d � \ rS rSrS\S\S 4 S\\S4 S\\ \4 SS4S jr28S \ SS4S29 jr S r
g) �_stream_wrapper�# �coro.N�args�kwargs�returnc �R � [ R " U5 U l X l X0l g �N)�types� coroutiner r r )�selfr r r s �^D:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/payload_streamer.py�__init__�_stream_wrapper.__init__$ s � � �O�O�D�)�� �� � � � �writerc � �t # � U R " U/U R Q70 U R D6I S h v�N g N7fr )r r r �r r s r �__call__�_stream_wrapper.__call__. s) � � ��i�i��:����:�d�k�k�:�:�:�s �.8�6�8)r r r )�__name__�30__module__� __qualname__�__firstlineno__r r r r r �strr r r �__static_attributes__� r r r r # s_ � � ��s�I�d�O�+�,� � �C��H�o� � �S�#�X�� �31 32� �;�%9� ;�d� ;r r c �L � \ rS rSrS\S\S 4 SS4S jrS\S\S\4S jr S33r34g) r �2 r .Nr c �D � [ R " S[ SS9 Xl g )Nz5@streamer is deprecated, use async generators instead� )�35stacklevel)�warnings�warn�DeprecationWarningr )r r s r r �streamer.__init__3 s � ��
�
� C� �� 36�37 � r r r c �. � [ U R X5 $ r )r r )r r r s r r �streamer.__call__; s � � �t�y�y�$�7�7r )r ) r" r# r$ r% r r r r r r r' r( r r r r 2 s= � ��X�c�9�T�?�&:� ;� �� �8�c� 8�S� 8�_� 8r r c �@ � \ rS rSrS\SS4S jrS38S\S\S\4S jjrS rg) �StreamWrapperPayload�? r r Nc � �B # � U R U5 I S h v�N g N7fr ��_valuer s r �write�StreamWrapperPayload.writeA � � � ��k�k�&�!�!�!�� � � � �encoding�errorsc � � [ S5 e)NzUnable to decode.)� TypeError)r r> r? s r �decode�StreamWrapperPayload.decodeD s � ��+�,�,r r( )zutf-8�strict) r" r# r$ r% r r: r& rB r' r( r r r5 r5 ? s5 � �"�"6� "�4� "�-�s� -�c� -�� -� -r r5 c �N ^ � \ rS rSrS\S\S\SS4U 4S jjrS\SS4S jrS39rU =r $ ) �
StreamPayload�H �valuer r r Nc �8 >� [ TU ] " U" 5 /UQ70 UD6 g r )�superr )r rH r r � __class__s �r r �StreamPayload.__init__J s �� �
�����2�4�2�6�2r r c � �B # � U R U5 I S h v�N g N7fr r8 r s r r: �StreamPayload.writeM r< r= r( )40r" r# r$ r% r r r r: r' �
__classcell__)rK s @r rF rF H s= �� �3�c� 3�#� 3�� 3�� 3�"�"6� "�4� "� "r rF )�__doc__r r. �typingr r r r r �abcr �payloadr41 r �__all__r r r5 rF r( r r �<module>rU sx ���0
� � 8� 8� %� *�42�� ;� ;� 438� 448� �o� �-�7� -� �-� �h��"�(� "� �"r