a !f@sPddlmZddlZddlmZmZmZddlZ Gdddej j e j j j Z dS))absolute_importN)AnyNoReturnOptionalcsXeZdZdZedddZedddZedfdd Z e e d fd d Z Z 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. )returncCs | S)zGReturn ``True`` if the associated Pub/Sub action has not yet completed.)doneselfr _/var/www/html/python-backend/venv/lib/python3.9/site-packages/google/cloud/pubsub_v1/futures.pyrunning!szFuture.runningcCs tddS)Nz9Only used by executors from `concurrent.futures` package.)NotImplementedErrorr r r r set_running_or_notify_cancel%sz#Future.set_running_or_notify_cancelresultcstj|dS)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__r r r*szFuture.set_result exceptioncstj|dS)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 rrr r r2szFuture.set_exception)__name__ __module__ __qualname____doc__boolr rrrrr BaseExceptionr __classcell__r r rr rs  r) __future__rconcurrent.futures concurrenttypingrrrZgoogle.api_core.futureZgooglefuturesrZapi_corefuturer r r r s