SSKJrJr SSKJrJrJrJrJr SSK J r SSK J r J r Jr "SS\\S9r\\ \\\\ /\4rg) )abstractmethodABCMeta)AsyncContextManagerCallableListSetOptional)Message)SubscriptionPathFlowControlSettings Partitionc6\rSrSrSr\S\\4Sj5rSr g)AsyncSingleSubscriberzz A Cloud Pub/Sub asynchronous subscriber. Must be used in an `async with` block or have __aenter__() awaited before use. returnc# [5e7f)ai 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.pyreadAsyncSingleSubscriber.read"s"##s N) __name__ __module__ __qualname____firstlineno____doc__rrr r__static_attributes__rrrrs& $DM$$rr) metaclassN)abcrrtypingrrrrr )google.cloud.pubsub_v1.subscriber.messager google.cloud.pubsublite.typesr r r rAsyncSubscriberFactoryrrrr&sU(EE=$/7$2"xI/1DEr