ddlmZmZddlmZmZmZmZmZddl m Z ddl m Z m Z mZGddeeZee eeee gefZy) )abstractmethodABCMeta)AsyncContextManagerCallableListSetOptional)Message)SubscriptionPathFlowControlSettings Partitionc,eZdZdZedeefdZy)AsyncSingleSubscriberz A Cloud Pub/Sub asynchronous subscriber. Must be used in an `async with` block or have __aenter__() awaited before use. returncKtw)a Read the next batch off of the stream. Returns: The next batch of messages. ack() or nack() must eventually be called exactly once on each message. Pub/Sub Lite does not support nack() by default- if you do call nack(), it will immediately fail the client unless you have a NackHandler installed. Raises: GoogleAPICallError: On a permanent error. )NotImplementedError)selfs Qlib/third_party/google/cloud/pubsublite/cloudpubsub/internal/single_subscriber.pyreadzAsyncSingleSubscriber.read"s"##s N)__name__ __module__ __qualname____doc__rrr rrrrs& $DM$$rr) metaclassN)abcrrtypingrrrrr )google.cloud.pubsub_v1.subscriber.messager google.cloud.pubsublite.typesr r r rAsyncSubscriberFactoryrrrr"sU(EE=$/7$2"xI/1DEr