+ [mÀh ãó>€^RIHt^RIHt^RIHt!RR4tR#)é)Ú lru_cache)Úaccepts_kwargs)ÚInvalidSubscriberMethodErrorcójaa€]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). cóB<€VP4\SV` V4#)N)Ú_validate_subscriber_methodsÚsuperÚ__new__)ÚclsÚargsÚkwargsÚ __class__s&*,€Ú8/usr/lib/python3/dist-packages/s3transfer/subscribers.pyr ÚBaseSubscriber.__new__sø€Ø ×(Ñ(Ô*܉w‰˜sÓ#Ð#ócóÒ€VPFVp\VRV,4p\V4'g\RV R24h\ V4'dKI\RV R24h R#)Úon_zSubscriber method z must be callable.z) must accept keyword arguments (**kwargs)N)ÚVALID_SUBSCRIBER_TYPESÚgetattrÚcallablerr)r Úsubscriber_typeÚsubscriber_methods& rr Ú+BaseSubscriber._validate_subscriber_methods s|€ð #×9Ô9ˆOÜ '¨¨U°_Õ-DÓ EÐ ÜÐ-×.Ò.Ü2Ø(Ð):Ð(;Ð;MÐNóðô"Ð"3×4Ô4Ü2Ø(Ð):Ð(;ð<+ð+óðó :rc ó€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Úfuturers&&,rÚ on_queuedÚBaseSubscriber.on_queued0ó€ñ rc ó€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)rrÚbytes_transferredrs&&&,rÚ on_progressÚBaseSubscriber.on_progress?s€ñ rc ó€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. Nrrs&&,rÚon_doneÚBaseSubscriber.on_doneQr"rr)ÚqueuedÚprogressÚdone)Ú__name__Ú __module__Ú __qualname__Ú__firstlineno__Ú__doc__rr Ú classmethodrr r r%r(Ú__static_attributes__Ú__classdictcell__Ú __classcell__)rÚ __classdict__s@@rrrsGù‡€ñò <Ðõ$ðØñ óóð ò  ò ÷$  ò  rrN)Ú functoolsrÚs3transfer.compatrÚs3transfer.exceptionsrrrrrÚr:sðõ å,Ý>÷K óK r