HEX
Server: LiteSpeed
System: Linux php-prod-1.spaceapp.ru 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64
User: xnsbb3110 (1041)
PHP: 8.1.33
Disabled: NONE
Upload Files
File: //usr/local/CyberCP/lib/python3.10/site-packages/s3transfer/__pycache__/subscribers.cpython-310.pyc
o

�h#�@s6ddlmZddlmZddlmZGdd�d�ZdS)�)�	lru_cache)�accepts_kwargs)�InvalidSubscriberMethodErrorcsReZdZdZgd�Z�fdd�Zee�dd���Zdd�Z	d	d
�Z
dd�Z�ZS)
�BaseSubscriberz�The base subscriber class

    It is recommended that all subscriber implementations subclass and then
    override the subscription methods (i.e. on_{subsribe_type}() methods).
    )�queued�progress�donecs|��t��|�S)N)�_validate_subscriber_methods�super�__new__)�cls�args�kwargs��	__class__��I/usr/local/CyberCP/lib/python3.10/site-packages/s3transfer/subscribers.pyrszBaseSubscriber.__new__cCsF|jD]}t|d|�}t|�std|��t|�s td|��qdS)N�on_z&Subscriber method %s must be callable.z=Subscriber method %s must accept keyword arguments (**kwargs))�VALID_SUBSCRIBER_TYPES�getattr�callablerr)r�subscriber_type�subscriber_methodrrrr	 s 
������z+BaseSubscriber._validate_subscriber_methodscK�dS)a�Callback to be invoked when transfer request gets queued

        This callback can be useful for:

            * Keeping track of how many transfers have been requested
            * Providing the expected transfer size through
              future.meta.provide_transfer_size() so a HeadObject would not
              need to be made for copies and downloads.

        :type future: s3transfer.futures.TransferFuture
        :param future: The TransferFuture representing the requested transfer.
        Nr��self�futurerrrr�	on_queued1�
zBaseSubscriber.on_queuedcKr)ajCallback to be invoked when progress is made on transfer

        This callback can be useful for:

            * Recording and displaying progress

        :type future: s3transfer.futures.TransferFuture
        :param future: The TransferFuture representing the requested transfer.

        :type bytes_transferred: int
        :param bytes_transferred: The number of bytes transferred for that
            invocation of the callback. Note that a negative amount can be
            provided, which usually indicates that an in-progress request
            needed to be retried and thus progress was rewound.
        Nr)rr�bytes_transferredrrrr�on_progress@szBaseSubscriber.on_progresscKr)a�Callback to be invoked once a transfer is done

        This callback can be useful for:

            * Recording and displaying whether the transfer succeeded or
              failed using future.result()
            * Running some task after the transfer completed like changing
              the last modified time of a downloaded file.

        :type future: s3transfer.futures.TransferFuture
        :param future: The TransferFuture representing the requested transfer.
        Nrrrrr�on_doneRrzBaseSubscriber.on_done)
�__name__�
__module__�__qualname__�__doc__rr�classmethodrr	rr r!�
__classcell__rrrrrsrN)�	functoolsr�s3transfer.compatr�s3transfer.exceptionsrrrrrr�<module>s