Ë €Ï†ãóN—ddlmZmZddlmZmZddlmZmZGd„dee¬«Z y)é)ÚabstractmethodÚABCMeta)ÚAsyncContextManagerÚList)ÚSequencedMessageÚFlowControlRequestcój—eZdZdZedeejjfd„«Z ede fd„«Z y)Ú Subscriberz? A Pub/Sub Lite asynchronous wire protocol subscriber. ÚreturncƒóK—t«‚­w)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ÚreadzSubscriber.readsèø€ô"Ó#Ð#ùs‚ Úrequestcó—t«‚)z] Allow an additional amount of messages and bytes to be sent to this client. r )rrs rÚ allow_flowzSubscriber.allow_flow&s €ô "Ó#Ð#óN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrÚmetaÚpbrrr©rrr r sP„ñðð $˜DÐ!1×!6Ñ!6×!9Ñ!9Ñ:ò $óð $ðð$Ð"4ò$óñ$rr )Ú metaclassN) ÚabcrrÚtypingrrÚ google.cloud.pubsublite_v1.typesrrr rrrÚr!sð÷(ß,ßQô$Ð$°ö$r