SrSSKJr SSKJr SSKJr SSKJr SSKrSSKJ r SSK J r SS K J r SS K Jr SS KJr SS KJr SS KJr SSKJr SSKJr Sr"SS\R05rSr"SS\5rg)z)Utilities for Pub/Sub Lite subscriptions.)absolute_import)division)unicode_literals)futuresN)Optional) cloudpubsub)types) PubsubMessage) lite_util) exceptions) gapic_util)log)queuelc\rSrSrSrSrg)SubscribeOperationException&z2Error when something went wrong while subscribing.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r7lib/googlecloudsdk/api_lib/pubsub/lite_subscriptions.pyrr&s:rrcP[R"[R"5S9$)N) credentials)rSubscriberClientr GetGapicCredentialsrrrGetDefaultSubscriberClientr *s!  % %002 44rcP\rSrSrSrS SjrSrSrSrSr S \ \ 4S jr S r g) r/z4GCloud wrapper client for a Pub/Sub Lite subscriber.NcLU=(d [5Ul[R"5UlUR U5UlUVs1sHn[R"U5iM snUl [R"U[S9Ul X@l SUlgs snf)N)messages_outstandingbytes_outstanding)r _clientrQueue _messages_SubscriptionResourceToPath _subscriptionr Partition _partitionsFlowControlSettings _MAX_INT64_flow_control_settings _auto_ack _pull_future)selfsubscription_resource partitions max_messagesauto_ackclient partitions r__init__SubscriberClient.__init__2s 979DL[[]DN99:OPDDNOJy 2JOD"'";";)$#DND Ps B!cURR5 URRURURR UR URS9UlU$)N)callback#per_partition_flow_control_settingsfixed_partitions) r& __enter__ subscriber*r(putr/r,r1)r2s rr?SubscriberClient.__enter__Cs]LL .. ##,0,G,G)) /+D KrcD[R"S5 URR5(d5URR 5 URR 5 URRXU5 g![ Ra N3f=f)N) timesleepr1donecancelresultrCancelledErrorr&__exit__)r2exc_type exc_value tracebacks rrKSubscriberClient.__exit__Ls}JJqM    ! ! # #    "   " LL(y9 # #   s4BBBc[R"[R"UR5[R "UR 5URS9$)N)projectlocationname)r SubscriptionPathr ProjectIdToProjectNumber projectsIdLocationToZoneOrRegion locationsIdsubscriptionsId)r2resources rr),SubscriberClient._SubscriptionResourceToPathXsF  ! !2283F3FG11(2F2FG  % % ''rc URR5(aeURR5nU(a[SR US95e[ R "S5 [R"S5eg)Nz.Subscribe operation failed with error: {error})errorzNThe streaming pull future completed unexpectedly without raising an exception.z-The subscribe stream terminated unexpectedly.) r1rG exceptionrformatrdebugr InternalError)r2es r_RaiseIfFailedSubscriberClient._RaiseIfFailed^sz     % % 'a ) < C C! C LN N ii()  $ $ 9 ;; rreturncUR5 URRSS9nUR(aUR 5 U$![ R a gf=f)z~Pulls and optionally acks a message from the provided subscription. Returns: A PubsubMessage pulled from the subscription. rD)timeoutN)rcr(getr0ackrEmpty)r2messages rPullSubscriberClient.PullisW  ""1"-g  n ;; s;AA%$A%)r0r&r/r(r,r1r*)N)rrrrrr9r?rKr)rcrr rlrrrrrr/s4< " :' ; H]+ rr)r __future__rrr concurrentrrEtypingrgoogle.cloud.pubsubliterr google.pubsub_v1r !googlecloudsdk.command_lib.pubsubr googlecloudsdk.corer r r six.movesrr.Errorrr objectrrrrrxs^ 0&' /)*7**#  ;*"2"2;4 GvGr