Server : LiteSpeed
System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64
User : nandedex ( 1060)
PHP Version : 8.1.33
Disable Function : NONE
Directory :  /opt/cppython/lib/python3.8/site-packages/s3transfer/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]


Current File : //opt/cppython/lib/python3.8/site-packages/s3transfer/__pycache__/subscribers.cpython-38.pyc
U

P��g	�@s6ddlmZddlmZddlmZGdd�d�ZdS)�)�	lru_cache)�accepts_kwargs)�InvalidSubscriberMethodErrorcsReZdZdZdddgZ�fdd�Zeedd���Zd	d
�Z	dd�Z
d
d�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).
    Zqueued�progress�donecs|��t��|�S)N)�_validate_subscriber_methods�super�__new__)�cls�args�kwargs��	__class__��C/opt/cppython/lib/python3.8/site-packages/s3transfer/subscribers.pyr
szBaseSubscriber.__new__cCsN|jD]B}t|d|�}t|�s0td|�d���t|�std|�d���qdS)NZon_zSubscriber method z must be callable.z) must accept keyword arguments (**kwargs))�VALID_SUBSCRIBER_TYPES�getattr�callablerr)rZsubscriber_typeZsubscriber_methodrrrr s

�
�z+BaseSubscriber._validate_subscriber_methodscKsdS)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�futurer
rrr�	on_queued0s
zBaseSubscriber.on_queuedcKsdS)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)rrZbytes_transferredr
rrr�on_progress?szBaseSubscriber.on_progresscKsdS)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_doneQs
zBaseSubscriber.on_done)
�__name__�
__module__�__qualname__�__doc__rr
�classmethodrrrrr�
__classcell__rrrrrs
rN)�	functoolsrZs3transfer.compatrZs3transfer.exceptionsrrrrrr�<module>
s

F1le Man4ger