ó €Ï†ãóH•SSKJrJr SSKJrJr SSKJrJr "SS\\S9r g)é)ÚabstractmethodÚABCMeta)ÚAsyncContextManagerÚList)ÚSequencedMessageÚFlowControlRequestcóv•\rSrSrSr\S\\RR4Sj5r \S\ 4Sj5r Sr g) Ú Subscriberéz7 A Pub/Sub Lite asynchronous wire protocol subscriber. Úreturncƒó# •[5e7f)zŠ Read a batch of messages off of the stream. Returns: The next batch of messages. Raises: GoogleAPICallError: On a permanent error. ©ÚNotImplementedError)Úselfs ÚClib/third_party/google/cloud/pubsublite/internal/wire/subscriber.pyÚreadÚSubscriber.readsé€ô"Ó#Ð#ùs‚ Úrequestcó•[5e)zM Allow an additional amount of messages and bytes to be sent to this client. r)rrs rÚ allow_flowÚSubscriber.allow_flow&s €ô "Ó#Ð#ó©N)Ú__name__Ú __module__Ú __qualname__Ú__firstlineno__Ú__doc__rrrÚmetaÚpbrrrÚ__static_attributes__rrrr r sP†ñðð $˜DÐ!1×!6Ñ!6×!9Ñ!9Ñ:ó $óð $ðð$Ð"4ó$óó$rr )Ú metaclassN) ÚabcrrÚtypingrrÚ google.cloud.pubsublite_v1.typesrrr rrrÚr&sð÷(ß,ßQô$Ð$°ó$r