B f’»daã@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>x0|D]}t||dƒ}|dk rPqWtdƒ‚n|}t|tƒrR|}n|j}t |¡}t|ddƒ} |dkr | dkr†tdƒ‚t   | dd¡} || 7}x<|  || ||¡2y 3dH} Wn t k sÒX| Vq²YWdS)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)) ) ÚaudioÚdocumentZphotoZstickerZ animationÚvideoZvoiceZ 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ÚStopAsyncIteration) rr r r Zavailable_mediaÚkindZmediaZ file_id_strZ file_id_objrÚchunksÚchunk©rúJ/tmp/pip-unpacked-wheel-rcokkf2l/pyrogram/methods/messages/stream_media.pyÚ stream_medias(0       *zStreamMedia.stream_mediaN)rr) Ú__name__Ú __module__Ú __qualname__rrÚintrrrrrrrrsr) rÚtypingrrrZpyrogramrZpyrogram.file_idrrrrrrÚs