a ù!f'ã@s~ddlmZddlZddlmZddlmZddlmZddlmZej rVddl m Z Gdd „d ej ƒZ Gd d „d ej ƒZ dS) é)Úabsolute_importN)ÚAny)ÚUnion)Úfutures)ÚAcknowledgeStatus)ÚStreamingPullManagercsReZdZdZddœ‡fdd„ Zdedœdd„Zed œd d „Zed œd d „Z ‡Z S)ÚStreamingPullFuturea<Represents a process that asynchronously performs streaming pull and schedules messages to be processed. This future is resolved when the process is stopped (via :meth:`cancel`) or if it encounters an unrecoverable error. Calling `.result()` will cause the calling thread to block indefinitely. r)Úmanagercs,tt|ƒ ¡||_|j |j¡d|_dS)NF)ÚsuperrÚ__init__Ú_StreamingPullFuture__managerZadd_close_callbackÚ_on_close_callbackÚ_StreamingPullFuture__cancelled)Úselfr ©Ú __class__©új/var/www/html/python-backend/venv/lib/python3.9/site-packages/google/cloud/pubsub_v1/subscriber/futures.pyr 'szStreamingPullFuture.__init__)r ÚresultcCs.| ¡r dS|dur | d¡n | |¡dS)NT)ÚdoneÚ set_resultÚ set_exception)rr rrrrr -s  z&StreamingPullFuture._on_close_callback©ÚreturncCsd|_|j ¡dS)a¡Stops pulling messages and shutdowns the background thread consuming messages. The method always returns ``True``, as the shutdown is always initiated. However, if the background stream is already being shut down or the shutdown has completed, this method is a no-op. .. versionchanged:: 2.4.1 The method does not block anymore, it just triggers the shutdown and returns immediately. To block until the background stream is terminated, call :meth:`result()` after cancelling the future. .. versionchanged:: 2.10.0 The method always returns ``True`` instead of ``None``. T)rr Úclose©rrrrÚcancel8s zStreamingPullFuture.cancelcCs|jS)zW Returns: ``True`` if the subscription has been cancelled. )rrrrrÚ cancelledNszStreamingPullFuture.cancelled) Ú__name__Ú __module__Ú __qualname__Ú__doc__r rr ÚboolrrÚ __classcell__rrrrrs  rcsNeZdZdZedœdd„Zedœdd„Zd eee fe dœ‡fd d „ Z ‡Z S) ÚFuturez¡This future object is for subscribe-side calls. Calling :meth:`result` will resolve the future by returning the message ID, unless an error occurs. rcCsdS©ziActions in Pub/Sub generally may not be canceled. This method always returns ``False``. Frrrrrr]sz Future.cancelcCsdSr%rrrrrrdszFuture.cancelledN)Útimeoutrcstƒj|dS)aDReturn a success code or raise an exception. This blocks until the operation completes successfully and returns the error code unless an exception is raised. Args: timeout: The number of seconds before this call times out and raises TimeoutError. Returns: AcknowledgeStatus.SUCCESS if the operation succeeded. Raises: concurrent.futures.TimeoutError: If the request times out. AcknowledgeError: If the operation did not succeed for another reason. )r&)r r)rr&rrrrksz Future.result)N) rrr r!r"rrrÚintÚfloatrrr#rrrrr$Vsr$)Ú __future__rÚtypingrrZgoogle.cloud.pubsub_v1rZ,google.cloud.pubsub_v1.subscriber.exceptionsrÚ TYPE_CHECKINGZBgoogle.cloud.pubsub_v1.subscriber._protocol.streaming_pull_managerrr$rrrrrÚs      8