%SSKJrJr SSKJrJrJrJrJrJ r J r SSK J r SSK Jr SSKJrJrJr "SS\\S9r\\/S 4r"S S \\S9rg ) )abstractmethodABCMeta)ContextManagerUnionAsyncContextManager AsyncIteratorCallableOptionalSet)StreamingPullFuture)Message)SubscriptionPathFlowControlSettings Partitionc ^\rSrSrSr\S S\\\4S\ S\ \ \ S\ \4Sjj5rS rg) AsyncSubscriberClientInterface$z An AsyncSubscriberClientInterface 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. N subscription#per_partition_flow_control_settingsfixed_partitionsreturnc# [5e7f)a Read messages from a subscription. Args: subscription: The subscription to subscribe to. 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. fixed_partitions: A fixed set of partitions to subscribe to. If not present, will instead use auto-assignment. Returns: An AsyncIterator with Messages that must have ack() called on each exactly once. Raises: GoogleApiCallError: On a permanent failure. NotImplementedError)selfrrrs Rlib/third_party/google/cloud/pubsublite/cloudpubsub/subscriber_client_interface.py subscribe(AsyncSubscriberClientInterface.subscribe-s,"##s N)__name__ __module__ __qualname____firstlineno____doc__rrrstrrr r rrr r__static_attributes__rrrr$s` 6: $,c12$.A$#3y>2 $ w  $$r(r) metaclassNc \\rSrSrSr\S S\\\4S\ S\ S\ \ \ S\4 S jj5rS rg) SubscriberClientInterfaceIz A SubscriberClientInterface 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. Nrcallbackrrrc[5e)a This method starts a background thread to begin pulling messages from a Pub/Sub Lite subscription and scheduling them to be processed using the provided ``callback``. Args: subscription: The subscription to subscribe to. callback: The callback function. This function receives the message as its only argument. 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. fixed_partitions: A fixed set of partitions to subscribe to. If not present, will instead use auto-assignment. Returns: A StreamingPullFuture instance that can be used to manage the background stream. Raises: GoogleApiCallError: On a permanent failure. r)rrr-rrs rr#SubscriberClientInterface.subscribeQs 4"##r(rr )r!r"r#r$r%rrrr&MessageCallbackrr r rr rr'rr(rr+r+Ise 6: $,c12$"$.A $ #3y>2 $  $$r(r+)abcrrtypingrrrrr r r )google.cloud.pubsub_v1.subscriber.futuresr )google.cloud.pubsub_v1.subscriber.messager google.cloud.pubsublite.typesrrrrr0r+rr(rr6s\(J=$%8G$DG9d?+"$'"$r(