%ddlmZmZddlmZmZmZmZmZm Z m Z ddl m Z ddl mZddlmZmZmZGddeeZeegd fZGd d eeZy ) )abstractmethodABCMeta)ContextManagerUnionAsyncContextManager AsyncIteratorCallableOptionalSet)StreamingPullFuture)Message)SubscriptionPathFlowControlSettings Partitionc ReZdZdZe ddeeefdede e e de e fdZy) AsyncSubscriberClientInterfacea 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_partitionsreturncKtw)at 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 subscribez(AsyncSubscriberClientInterface.subscribe-s,"##s N)__name__ __module__ __qualname____doc__rrrstrrr r rrr rrrr$s` 6: $,c12$.A$#3y>2 $ w  $$r$r) metaclassNc PeZdZdZe d deeefdede de e e de f dZy) SubscriberClientInterfacez 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. Nrcallbackrrrct)al 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 rrz#SubscriberClientInterface.subscribeQs 4"##r$r)rrr r!rrrr"MessageCallbackrr r rr rr#r$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.typesrrrrr*r'r#r$rr0s\(J=$%8G$DG9d?+"$'"$r$