a !fS @s\ddlmZddlZddlmZmZmZddlmZejrFddl m Z Gdddej Z dS))absolute_importN)AnyCallableUnion)futures) pubsub_v1csleZdZdZedddZedddZdeee fe dfd d Z e d ge fdd fd d ZZS)FuturezThis future object is returned from asychronous Pub/Sub publishing calls. Calling :meth:`result` will resolve the future by returning the message ID, unless an error occurs. )returncCsdSziActions in Pub/Sub generally may not be canceled. This method always returns ``False``. Fselfr r i/var/www/html/python-backend/venv/lib/python3.9/site-packages/google/cloud/pubsub_v1/publisher/futures.pycancel"sz Future.cancelcCsdSr r r r r r cancelled)szFuture.cancelledN)timeoutr cstj|dS)a$Return the message ID or raise an exception. This blocks until the message has been published successfully and returns the message ID unless an exception is raised. Args: timeout: The number of seconds before this call times out and raises TimeoutError. Returns: The message ID. Raises: concurrent.futures.TimeoutError: If the request times out. Exception: For undefined exceptions in the underlying call execution. )r)superresult)r r __class__r rr0sz Future.resultz"pubsub_v1.publisher.futures.Future)callbackr cs t|S)a9Attach a callable that will be called when the future finishes. Args: callback: A callable that will be called with this future as its only argument when the future completes or is cancelled. The callable will always be called by a thread in the same process in which it was added. If the future has already completed or been cancelled then the callable will be called immediately. These callables are called in the order that they were added. )radd_done_callback)r rrr rrEszFuture.add_done_callback)N)__name__ __module__ __qualname____doc__boolrrrintfloatstrrrrr __classcell__r r rrrs r) __future__rtypingrrrZgoogle.cloud.pubsub_v1r TYPE_CHECKINGZ google.cloudrrr r r rs