ó €Ïïãó°•SSKJr SSKrSSKJrJrJr SSKr "SS\RR\ RRR5r g)é)Úabsolute_importN)ÚAnyÚNoReturnÚOptionalcój^•\rSrSrSrS\4SjrS\4SjrS\ 4U4Sjjr S\ \ 4U4S jjr S rU=r$) ÚFutureéaEncapsulation of the asynchronous execution of an action. This object is returned from asychronous Pub/Sub calls, and is the interface to determine the status of those calls. This object should not be created directly, but is returned by other methods in this library. Úreturncó,•UR5(+$)zGReturn ``True`` if the associated Pub/Sub action has not yet completed.)Údone©Úselfs Ú1lib/third_party/google/cloud/pubsub_v1/futures.pyÚrunningÚFuture.running!s€à—9‘9“;ŒÐócó•[S5e)Nz9Only used by executors from `concurrent.futures` package.)ÚNotImplementedErrorr s rÚset_running_or_notify_cancelÚ#Future.set_running_or_notify_cancel%s€Ü!Ø Gó ð rÚresultcó>•[TU]US9$)z—Set the return value of work associated with the future. Do not use this method, it should only be used internally by the library and its unit tests. )r)ÚsuperÚ set_result)rrÚ __class__s €rrÚFuture.set_result*sø€ô ‰wÑ!¨Ð!Ð0Ð0rÚ exceptioncó>•[TU]US9$)z™Set the result of the future as being the given exception. Do not use this method, it should only be used internally by the library and its unit tests. )r)rÚ set_exception)rrrs €rrÚFuture.set_exception2sø€ô ‰wÑ$¨yÐ$Ð9Ð9r©)Ú__name__Ú __module__Ú __qualname__Ú__firstlineno__Ú__doc__ÚboolrrrrrrÚ BaseExceptionrÚ__static_attributes__Ú __classcell__)rs@rrrsBø†ñð˜ôð ¨hô ð 1 ÷1ð: x° Ñ'>÷:õ:rr)Ú __future__rÚconcurrent.futuresÚ concurrentÚtypingrrrÚgoogle.api_core.futureÚgoogleÚfuturesrÚapi_coreÚfuturer!rrÚr4s@ðõ'ãß*Ñ*ãô!:ˆZ× Ñ × &Ñ &¨¯©×(>Ñ(>×(EÑ(Eõ!:r