'SSKJr SSKrSSKJr SSKJr SSKJr SSKJr \R(aSSK J r "SS \R5r "S S \R5r g) )absolute_importN)Any)Union)futures)AcknowledgeStatus)StreamingPullManagerc^^\rSrSrSrS U4SjjrSSS\4SjrS\4S jr S\4S jr S r U=r $) 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. managerrc>[[U] 5 XlURR UR 5 SUlg)NF)superr __init___StreamingPullFuture__manageradd_close_callback_on_close_callback_StreamingPullFuture__cancelled)selfr __class__s OOD !   v &rreturncFSUlURR5 g)aIStops 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)rrclosers rcancelStreamingPullFuture.cancel8s$  rcUR$)z? Returns: ``True`` if the subscription has been cancelled. )rr"s r cancelledStreamingPullFuture.cancelledNs r) __cancelled __manager)r r) __name__ __module__ __qualname____firstlineno____doc__rrrboolr#r&__static_attributes__ __classcell__rs@rr r s>! '*@ '# ', 4  rr cb^\rSrSrSrS\4SjrS\4SjrS S\\ \ 4S\ 4U4Sjjjr Sr U=r$) FutureVzThis future object is for subscribe-side calls. Calling :meth:`result` will resolve the future by returning the message ID, unless an error occurs. rcgzYActions in Pub/Sub generally may not be canceled. This method always returns ``False``. Fr"s rr# Future.cancel] rcgr7r8r"s rr&Future.cancelleddr:rtimeoutc>[TU]US9$)aReturn 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=)rr)rr=rs rr Future.resultks$w~g~..rr8)N)r*r+r,r-r.r/r#r&rintfloatrrr0r1r2s@rr4r4VsB 4/eCJ//;L//rr4) __future__rtypingrrgoogle.cloud.pubsub_v1r,google.cloud.pubsub_v1.subscriber.exceptionsr TYPE_CHECKINGBgoogle.cloud.pubsub_v1.subscriber._protocol.streaming_pull_managerrr4r r8rrrHsH' *J  5 '..5 p'/W^^'/r