ddlmZddlZddlmZmZmZddlZ Gddejje jjjZ y))absolute_importN)AnyNoReturnOptionalcVeZdZdZdefdZdefdZdeffd Z de e ffd Z xZ S) Futurea#Encapsulation 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$|j S)zGReturn ``True`` if the associated Pub/Sub action has not yet completed.)doneselfs 1lib/third_party/google/cloud/pubsub_v1/futures.pyrunningzFuture.running!s99;ctd)Nz9Only used by executors from `concurrent.futures` package.)NotImplementedErrorr s rset_running_or_notify_cancelz#Future.set_running_or_notify_cancel%s! G  rresultc$t||S)zSet 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)r r __class__s rrzFuture.set_result*s w!!00r exceptionc$t||S)zSet 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)r rrs rrzFuture.set_exception2s w$y$99r)__name__ __module__ __qualname____doc__boolrrrrrr BaseExceptionr __classcell__)rs@rrrsB h 11:x '>::rr) __future__rconcurrent.futures concurrenttypingrrrgoogle.api_core.futuregooglefuturesrapi_corefuturerrr-s@'**!:Z   & &(>(>(E(E!:r