+ €Ú,i cs>€^RIHt^RIHt^RIHt!RR4tR#)i)Ú lru_cache)Úaccepts_kwargs)ÚInvalidSubscriberMethodErrorcsjaa€]tRt^toRt.ROtV3Rlt]]R44t Rt Rt Rt Rt VtV;t#) ÚBaseSubscriberz«The base subscriber class It is recommended that all subscriber implementations subclass and then override the subscription methods (i.e. on_{subscribe_type}() methods). csB<€VP4\SV` V4#)N)Ú_validate_subscriber_methodsZsuperÚ__new__)ÚclsZargsÚkwargsÚ __class__s&*,€Ú;/usr/lib/python3.14/site-packages/s3transfer/subscribers.pyrZBaseSubscriber.__new__sø€Ø ×(Ñ(Ô*܉w‰˜sÓ#Ð#ócsÒ€VPFVp\VRV,4p\V4'g\RV R24h\ V4'dKI\RV R24h R#)Zon_zSubscriber method z must be callable.z) must accept keyword arguments (**kwargs)N)ÚVALID_SUBSCRIBER_TYPESZgetattrZcallablerr)rZsubscriber_typeZsubscriber_methods& r rZ+BaseSubscriber._validate_subscriber_methods s|€ð #×9Ô9ˆOÜ '¨¨U°_Õ-DÓ EÐ ÜÐ-×.Ò.Ü2Ø(Ð):Ð(;Ð;MÐNóðô"Ð"3×4Ô4Ü2Ø(Ð):Ð(;ð<+ð+óðó :r c ó€R#)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. N©©ÚselfÚfutureró&&,r Ú on_queuedZBaseSubscriber.on_queued0ó€ñ r c r )aCallback 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_transferredrs&&&,r Ú on_progressZBaseSubscriber.on_progress?s€ñ r c r )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. Nr rrr Úon_doneZBaseSubscriber.on_doneQrr r )ZqueuedZprogressZdone)Z__name__Z __module__Z __qualname__Z__firstlineno__Z__doc__r rZ classmethodrrrrrZ__static_attributes__Z__classdictcell__Z __classcell__)rZ __classdict__s@@r rrsGù‡€ñò <Ðõ$ðØñ óóð ò  ò ÷$  ò  r rN)Z functoolsrZs3transfer.compatrZs3transfer.exceptionsrrr r r Úrsðõ å,Ý>÷K óK r