%SSKJrJrJrJrJr SSKJr SSKJ r SSK J r SSK J r Jr SSKJrJr SSKJr SSKJr SS KJr SS KJrJr SS KJr SS KJr SS KJ r J!r! SSK"J#r# SSK$J%r% SSK&J'r' SSK(J)r) SSK*J+r+ SSK,J-r- SSK.J/r/ SSK0J1r1 SSK2J3r3 SSK4J5s J6s J7s J8s J9r: SSK;Jr> SSK?J@r@ SSKAJBrBJCrCJDrDJErEJFrFJGrG SSKHJIrI SSKJJKrK SSKLJMrM SrNS \>S!\OS"\ S#\\ S$\\\O\O4S%\'4 S&jrPS \>S!\OS"\ S#\\ S$\\\O\O4S'\S(\ S)\S%\4S*jrQS0S \>S!\OS+\S(\\ S,\\ S)\\S-\\\=S#\\ S"\\ S.\\\O\O4S%\#4S/jjrRg)1)OptionalMappingSet AsyncIteratorCallable)uuid4) ClientOptions) Credentials)ReassignmentHandlerDefaultReassignmentHandler)to_cps_subscribe_message#add_id_to_cps_subscribe_transformer) ClientCache)FlowControlSettings)AckSetTrackerImpl)PartitionSubscriberFactoryAssigningSingleSubscriber)SinglePartitionSingleSubscriber)MessageTransformer) NackHandlerDefaultNackHandler)AsyncSingleSubscriber)regional_endpoint)Assigner) AssignerImpl) CommitterImplFixedSetAssigner)GapicConnectionFactory)merge_metadata)pubsub_contextN)SubscriberResetHandler) PartitionSubscriptionPath)subscription_routing_metadata)SubscribeRequestInitialSubscribeRequestStreamingCommitCursorRequestPartitionAssignmentRequest!InitialPartitionAssignmentRequestInitialCommitCursorRequestSubscriberServiceAsyncClient)%PartitionAssignmentServiceAsyncClientCursorServiceAsyncClientg? subscription transportclient_options credentials base_metadatareturnc^^^^Tc0mS[[4UUUU4Sjjn[[[ U5[ 5R S9[U55$)Nrequestsch>[TTTS9nURU[TR55S9$)Nr4r2r3metadata)r.assign_partitionslistitems)r8assignment_clientr5r3r4r2s Olib/third_party/google/cloud/pubsublite/cloudpubsub/internal/make_subscriber.pyassignment_connection_factory=_make_dynamic_assigner..assignment_connection_factorybsIBken@NO 22 tM$7$7$9:3  )r1 client_id)rr)rr*strrbytesr)r1r2r3r4r5rBs ```` rA_make_dynamic_assignerrHXsZ   :;   )\*egmm  <=  rDflow_control_settings nack_handlermessage_transformerc^^^^^^^^^ ^ [UUU4Sj5m [UUU4Sj5m S[S[4UU UUUU U4SjjnU$)Nc>[TTTS9$Nr:r,r3r4r2srA4_make_partition_subscriber_factory..}s,#y rDc>[TTTS9$rNr/rOsrArPrQs(#y rD partitionr6c `>^^^[T[T T55mS[[4UU 4SjjmS[[4UU4SjjnS[ 4UUU 4Sjjn[ [[T 5TRS9[[U55n[U5n[UT UT [TT 55$)Nr8cn>TR5RU[TR55S9$Nr;)get subscriber>r?)r8final_metadatasubscribe_client_caches rAsubscribe_connection_factoryY_make_partition_subscriber_factory..factory..subscribe_connection_factorys7)--/994(<(<(>#?: rDcn>TR5RU[TR55S9$rV)rWstreaming_commit_cursorr>r?)r8cursor_client_cacherYs rAcursor_connection_factoryV_make_partition_subscriber_factory..factory..cursor_connection_factorys:'**,DD4(<(<(>#?E rD reset_handlerc>[R"[[T5TRS9[ [ T5U5$)Nr1rS)wire_subscriberSubscriberImplr'rFvalue_DEFAULT_FLUSH_SECONDSr)rbrSr[r1s rAsubscriber_factoryO_make_partition_subscriber_factory..factory..subscriber_factorys="11'!$\!2ioo'&'CD  rDrd)r r%rr&r(r"rr+rFrgrhrrrr)rSr`ri committerack_set_trackerrYr[r5r_rIrKrJrZr1s` @@rAfactory3_make_partition_subscriber_factory..factorys' 8yQ  =AQ3R    #$@A   .D  " & .)//  # "#< =  ,I6.  !   / ;N O   rD)rr#r) r1r2r3r4r5rIrJrKrmr_rZs ```````` @@rA"_make_partition_subscriber_factoryrorsI)  &  ) 9) )>) ) V NrD#per_partition_flow_control_settingsreassignment_handlerfixed_partitionsr<c `^^^^^^ [[SS9T 5m Tc&[[TRR 5S9mT(aU4Sjn O UUU UU4Sjn Uc [ 5nUc [5nUc[R"[5n[TTTTT UUU5n [XU5$)a Make a Pub/Sub Lite AsyncSubscriber. Args: subscription: The subscription to subscribe to. transport: The transport type to use. per_partition_flow_control_settings: The flow control settings for each partition subscribed to. Note that these settings apply to each partition individually, not in aggregate. nack_handler: An optional handler for when nack() is called on a Message. The default will fail the client. message_transformer: An optional transformer from Pub/Sub Lite messages to Cloud Pub/Sub messages. fixed_partitions: A fixed set of partitions to subscribe to. If not present, will instead use auto-assignment. credentials: The credentials to use to connect. GOOGLE_DEFAULT_CREDENTIALS is used if None. client_options: Other options to pass to the client. Note that if you pass any you must set api_endpoint. metadata: Additional metadata to send with the RPC. Returns: A new AsyncSubscriber. CLOUD_PUBSUB_SHIM) framework) api_endpointc>[T5$Nr)rrsrArP'make_async_subscriber..s #34D#ErDc">[TTTTT5$rx)rH)r3r4r<r1r2srArPrys#9      $ rD) r r!r rlocationregionrr r of_callabler ror) r1r2rprJrqrKrrr4r3r<assigner_factorypartition_subscriber_factorys `` ```` rAmake_async_subscriberrs<n7JKXVH&*<+@+@+G+GH E  )+ #9;"0<<=UV#E+ $  %8L rD)NNNNNNN)Stypingrrrrruuidrgoogle.api_core.client_optionsr google.auth.credentialsr 8google.cloud.pubsublite.cloudpubsub.reassignment_handlerr r 6google.cloud.pubsublite.cloudpubsub.message_transformsr r2google.cloud.pubsublite.internal.wire.client_cachergoogle.cloud.pubsublite.typesrAgoogle.cloud.pubsublite.cloudpubsub.internal.ack_set_tracker_implrAgoogle.cloud.pubsublite.cloudpubsub.internal.assigning_subscriberrrHgoogle.cloud.pubsublite.cloudpubsub.internal.single_partition_subscriberr7google.cloud.pubsublite.cloudpubsub.message_transformerr0google.cloud.pubsublite.cloudpubsub.nack_handlerrr>google.cloud.pubsublite.cloudpubsub.internal.single_subscriberr*google.cloud.pubsublite.internal.endpointsr.google.cloud.pubsublite.internal.wire.assignerr3google.cloud.pubsublite.internal.wire.assigner_implr4google.cloud.pubsublite.internal.wire.committer_implr8google.cloud.pubsublite.internal.wire.fixed_set_assignerr6google.cloud.pubsublite.internal.wire.gapic_connectionr4google.cloud.pubsublite.internal.wire.merge_metadatar 4google.cloud.pubsublite.internal.wire.pubsub_contextr!5google.cloud.pubsublite.internal.wire.subscriber_implcloud pubsubliteinternalwiresubscriber_implre>google.cloud.pubsublite.internal.wire.subscriber_reset_handlerr"r#r$1google.cloud.pubsublite.internal.routing_metadatar%google.cloud.pubsublite_v1r&r'r(r)r*r+Cgoogle.cloud.pubsublite_v1.services.subscriber_service.async_clientr-Mgoogle.cloud.pubsublite_v1.services.partition_assignment_service.async_clientr.?google.cloud.pubsublite_v1.services.cursor_service.async_clientr0rhrFrHrorrDrArs0CB8/K=WICLNUPOOOOF""+&  GCH-.   4@"@@"@+& @ GCH-. @ / @@,@ @N+/:>8<15)-.2,0A"AA*=A;' A ##67 A ""45 As9~.A+&A]+AwsCx()AArD