o -j@sNddlZddlmZmZmZddlZddlmZddlmZGdddZ dS)N)UnionOptionalBinaryIO)types)FileIdc@sDeZdZ  d dddedefdededeeeeff d d Zd S) StreamMediarselfzpyrogram.Clientmessagez types.Messagelimitoffsetreturnc Csd}t|tjr|D]}t||d}|durnq tdn|}t|tr)|}n|j}t|}t|dd} |dkrP| dkrCtdt | dd} || 7}| || ||2z 3dHW} | VqX6dS)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)) ) audiodocumentphotosticker animationvideovoice video_notenew_chat_photoNz3This message doesn't contain any downloadable media file_sizerzNNegative offsets are not supported for file ids, pass a Message object insteadi) isinstancerMessagegetattr ValueErrorstrfile_idrdecodemathceilget_file) rr r r available_mediakindmedia file_id_str file_id_objrchunkschunkr(c/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/pyrogram/methods/messages/stream_media.py stream_medias00     zStreamMedia.stream_mediaN)rr) __name__ __module__ __qualname__rrintrrr*r(r(r(r)rs r) rtypingrrrpyrogramrpyrogram.file_idrrr(r(r(r)s