SSKJr SSKJrJrJrJr SSKJr SSK J r SSK J r SSK Jr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJrJrJr SSKJ r SSK!J"r" SSK#J$r$J%r%J&r& "SS\\ 5r'"SS\\ 5r(g))ThreadPoolExecutor)OptionalUnionSet AsyncIterator) ClientOptions) Credentials)StreamingPullFuture)Message)ReassignmentHandlermake_async_subscriber) MultiplexedAsyncSubscriberClient)MultiplexedSubscriberClient)MessageTransformer) NackHandler)SubscriberClientInterfaceAsyncSubscriberClientInterfaceMessageCallback)ConstructableFromServiceAccount)RequireStarted)FlowControlSettings PartitionSubscriptionPathc\rSrSr%Sr\\S'\\S'SSSSSSSS.S\\ S \\ S \\ S \\ S \\ S \S\\4SjjrSS\\\4S\S\S\\\S\4 SjjrSrSrSrg)SubscriberClient3z A SubscriberClient reads messages similar to Google Pub/Sub. Any subscribe failures are unlikely to succeed if retried. Must be used in a `with` block or have __enter__() called before use. _impl_require_startedN grpc_asyncio)executor nack_handlerreassignment_handlermessage_transformer credentials transportclient_optionsr!r"r#r$r%r&r'c |^^^^^^Uc [5n[UUUUUUU4Sj5Ul[5Ulg)aX Create a new SubscriberClient. Args: executor: A ThreadPoolExecutor to use. The client will shut it down on __exit__. If provided a single threaded executor, messages will be ordered per-partition, but take care that the callback does not block for too long as it will impede forward progress on all subscriptions. nack_handler: A handler for when `nack()` is called. The default NackHandler raises an exception and fails the subscribe stream. message_transformer: A transformer from Pub/Sub Lite messages to Cloud Pub/Sub messages. This may not return a message with "message_id" set. credentials: If provided, the credentials to use when connecting. transport: The transport to use. Must correspond to an asyncio transport. client_options: The client options to use when connecting. If used, must explicitly set `api_endpoint`. Nc &>[UTUTTTUTTS9 $N) subscriptionr&#per_partition_flow_control_settingsr"r#r$fixed_partitionsr%r'r r+ partitionssettingsr'r%r$r"r#r&s Hlib/third_party/google/cloud/pubsublite/cloudpubsub/subscriber_client.py+SubscriberClient.__init__..X&7L)#4<)%9$7!+'- 8)rrrrr)selfr!r"r#r$r%r&r's ``````r1__init__SubscriberClient.__init__>s9,  )+H0      !/ 0r5r+callbackr,r-returncrURR5 URRUUUU5$Nrrequire_startedr subscribe)r6r+r9r,r-s r1r?SubscriberClient.subscribefs9 --/zz##   /    r5cnURR5 URR5 U$r<)r __enter__rr6s r1rBSubscriberClient.__enter__us) '')  r5ctURRXU5 URRXU5 gr<)r__exit__rr6exc_type exc_value tracebacks r1rFSubscriberClient.__exit__zs, H; &&xIFr5rrr<)__name__ __module__ __qualname____firstlineno____doc__r__annotations__rrrrr rr strrr7rrrrrrr r?rBrF__static_attributes__r5r1rr3s %$$$ 26.2>B<@-1'26&1-.&1{+ &1 '':; &1 &&89 &1k*&1&1!/&1Z6:  ,c12  "  .A  #3y>2     Gr5rc\rSrSr%Sr\\S'\\S'SSSSSSS.S\\ S \\ S \\ S \\ S \ S \\4 SjjrSS\\\ 4S\S\\\S\\4SjjrSrSrSrg)AsyncSubscriberClientz An AsyncSubscriberClient reads messages similar to Google Pub/Sub, but must be used in an async context. Any subscribe failures are unlikely to succeed if retried. Must be used in an `async with` block or have __aenter__() awaited before use. rrNr )r"r#r$r%r&r'r"r#r$r%r&r'c`^^^^^^[UUUUUU4Sj5Ul[5Ulg)aC Create a new AsyncSubscriberClient. Args: nack_handler: A handler for when `nack()` is called. The default NackHandler raises an exception and fails the subscribe stream. message_transformer: A transformer from Pub/Sub Lite messages to Cloud Pub/Sub messages. This may not return a message with "message_id" set. credentials: If provided, the credentials to use when connecting. transport: The transport to use. Must correspond to an asyncio transport. client_options: The client options to use when connecting. If used, must explicitly set `api_endpoint`. c &>[UTUTTTUTTS9 $r*r r.s r1r20AsyncSubscriberClient.__init__..r4r5N)rrrr)r6r"r#r$r%r&r's ``````r1r7AsyncSubscriberClient.__init__s((6     !/ 0r5r+r,r-r:c# URR5 URRXU5IShvN $N7fr<r=)r6r+r,r-s r1r?AsyncSubscriberClient.subscribes@ --/ZZ)) ?O    s:AAAc# URR5 URR5IShvN U$N7fr<)rrBr __aenter__rCs r1r` AsyncSubscriberClient.__aenter__s7 '')jj##%%%  &s8AAAc# URRXU5IShvN URRXU5 gN!7fr<)r __aexit__rrFrGs r1rcAsyncSubscriberClient.__aexit__s;jj""8 BBB &&xIF Cs AA"ArLr<)rMrNrOrPrQrrRrrrr rr rSrr7rrrrrrr r?r`rcrTrUr5r1rWrWs *)$$ /3>B<@-1'26!1{+!1'':; !1 &&89 !1 k* !1!1!/!1N6:  ,c12  .A  #3y>2  w    Gr5rWN))concurrent.futures.threadrtypingrrrrgoogle.api_core.client_optionsrgoogle.auth.credentialsr )google.cloud.pubsub_v1.subscriber.futuresr )google.cloud.pubsub_v1.subscriber.messager 8google.cloud.pubsublite.cloudpubsub.reassignment_handlerr rus9668/I=XWH LIG02QIGXCG"$CCGr5