Ë
|
¸^iñ ã óÔ 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« « Zy)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 óX e Zd Zdeded f deedf deeef ddfdZ de
|
ddfd Z y)
|
Ú_stream_wrapperÚcoro.NÚargsÚkwargsÚreturnc óT t j |« | _ || _ || _ y ©N)ÚtypesÚ coroutiner r r )Úselfr r r s õk H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/payload_streamer.pyÚ__init__z_stream_wrapper.__init__$ s" ô OO DÓ) Ø Ø ó Úwriterc ót K | j |g| j ¢i | j ¤ d { y 7 wr )r r r ©r r s r Ú__call__z_stream_wrapper.__call__. s, è ø ØdiiÐ: §¡Ò:¨d¯k©kÑ:×:Ò:ús .8°6±8) Ú__name__Ú
|
__module__Ú __qualname__r r r r r Ústrr r r © r r r r # s_ ð àsI dOÐ+Ñ,ð ð CHoð ð S#Xð ð
|
|
ó ð;Ð%9ð ;¸dô ;r r c ó@ e Zd Zdeded f ddfdZdededefdZy) r r .Nr c óJ t j dt d¬« || _ y )Nz5@streamer is deprecated, use async generators insteadé )Ú
|
stacklevel)ÚwarningsÚwarnÚDeprecationWarningr )r r s r r zstreamer.__init__3 s Ü Ø CÜ Øõ
|
ð
|
r r r c ó0 t | j ||« S r )r r )r r r s r r zstreamer.__call__; s Ü tyy¨$°Ó7Ð7r ) r r r! r r r r r r r# r r r r 2 s= ðX c¨9°T©?Ð&:Ñ ;ð Àó ð8cð 8¨Sð 8°_ô 8r r c ó2 e Zd ZdeddfdZddededefdZy) ÚStreamWrapperPayloadr r Nc óB K | j |« d { y 7 wr ©Ú_valuer s r ÚwritezStreamWrapperPayload.writeA ó è ø Økk&Ó!×!Ò!úó ÚencodingÚerrorsc ó t d« )NzUnable to decode.)Ú TypeError)r r4 r5 s r ÚdecodezStreamWrapperPayload.decodeD s ÜÐ+Ó,Ð,r )zutf-8Ústrict)r r r! r r1 r" r8 r# r r r- r- ? s0 ð"Ð"6ð "¸4ó "ñ-sð -°cð -Èô -r r- c ó@ e Zd Zdedededdf fd ZdeddfdZ xZS ) Ú StreamPayloadÚvaluer r r Nc ó6 t | |« g|¢i |¤ y r )Úsuperr )r r< r r Ú __class__s r r zStreamPayload.__init__J s ø Ü ÑÐ2 4Ò2¨6Ó2r r c óB K | j |« d { y 7 wr r/ r s r r1 zStreamPayload.writeM r2 r3 )r r r! r r r r1 Ú __classcell__)r? s @r r; r; H s8 ø ð3cð 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 sx ðñó0 Û ß 8Õ 8å %ß *à
|
÷ ;ñ ;÷
|
8ñ
|
8ñ oÓ ô-7ó -ó ð-ñ hÓô"Ð(ó "ó ñ"r
|
