U ç;ãgaã@sNddlZddlmZmZmZddlZddlmZddlmZGdd„dƒZ dS)éN)ÚUnionÚOptionalÚBinaryIO)Útypes)ÚFileIdc @s8eZdZddedefeeeeeefdœdd„ZdS) Ú StreamMediarzpyrogram.Clientz types.Message)ÚselfÚmessageÚlimitÚoffsetÚreturnc CsÈd}t|tjƒr<|D]}t||dƒ}|dk rq@qtdƒ‚n|}t|tƒrP|}n|j}t |¡}t|ddƒ} |dkrž| dkr„tdƒ‚t   | dd¡} || 7}|  || ||¡2z3dHW} | Vq®6dS)asStream the media from a message chunk by chunk. You can use this method to partially download a file into memory or to selectively download chunks of file. The chunk maximum size is 1 MiB (1024 * 1024 bytes). .. include:: /_includes/usable-by/users-bots.rst Parameters: message (:obj:`~pyrogram.types.Message` | ``str``): Pass a Message containing the media, the media itself (message.audio, message.video, ...) or a file id as string. limit (``int``, *optional*): Limit the amount of chunks to stream. Defaults to 0 (stream the whole media). offset (``int``, *optional*): How many chunks to skip before starting to stream. Defaults to 0 (start from the beginning). Returns: ``Generator``: A generator yielding bytes chunk by chunk Example: .. code-block:: python # Stream the whole media async for chunk in app.stream_media(message): print(len(chunk)) # Stream the first 3 chunks only async for chunk in app.stream_media(message, limit=3): print(len(chunk)) # Stream the rest of the media by skipping the first 3 chunks async for chunk in app.stream_media(message, offset=3): print(len(chunk)) # Stream the last 3 chunks only (negative offset) async for chunk in app.stream_media(message, offset=-3): print(len(chunk)) ) ZaudioZdocumentZphotoZstickerZ animationZvideoZvoiceZ video_noteZnew_chat_photoNz3This message doesn't contain any downloadable mediaÚ file_sizerzNNegative offsets are not supported for file ids, pass a Message object insteadi) Ú isinstancerÚMessageÚgetattrÚ ValueErrorÚstrZfile_idrÚdecodeÚmathÚceilZget_file) rr r r Zavailable_mediaÚkindZmediaZ file_id_strZ file_id_objr ÚchunksÚchunk©rúf/opt/bot/vods_filmes/script/venv/lib/python3.8/site-packages/pyrogram/methods/messages/stream_media.pyÚ stream_medias(0      zStreamMedia.stream_mediaN)rr) Ú__name__Ú __module__Ú __qualname__rrÚintrrrrrrrrsü ûr) rÚtypingrrrZpyrogramrZpyrogram.file_idrrrrrrÚs