.)ddlmZmZmZmZmZmZmZmZddl m Z GddZ GddZ GddZ Gd d Zy ) )Any AsyncIterator AwaitableCallableSequenceTupleOptionalIterator)schemac eZdZdZdddedej fdejdej dee e e ffd Z d e d e fd Z ed eej fd Zd eej"fdZd e fdZy)ListSchemasPageraA pager for iterating through ``list_schemas`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSchemasResponse` object, and provides an ``__iter__`` method to iterate through its ``schemas`` field. If there are more pages, the ``__iter__`` method will make additional ``ListSchemas`` requests and continue to iterate through the ``schemas`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSchemasResponse` attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup. metadatamethod.requestresponsercb||_tj||_||_||_y)aInstantiate the pager. Args: method (Callable): The method that was originally called, and which instantiated this pager. request (google.pubsub_v1.types.ListSchemasRequest): The initial request object. response (google.pubsub_v1.types.ListSchemasResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. N_methodr ListSchemasRequest_request _response _metadataselfrrrrs Blib/third_party/google/pubsub_v1/services/schema_service/pagers.py__init__zListSchemasPager.__init__0+( 11': !!namereturnc.t|j|SNgetattrrrr!s r __getattr__zListSchemasPager.__getattr__It~~t,,r c#BK|j|jjrw|jj|j_|j |j|j |_|j|jjrvyywNrrnext_page_tokenr page_tokenrrrs rpageszListSchemasPager.pagesLhnnnn,,'+~~'E'EDMM $!\\$--$..\QDN.. nn,, BBBc#ZK|jD]}|jEd{y7wr$r0schemasrpages r__iter__zListSchemasPager.__iter__T$JJD|| # # # +)+cbdj|jj|jSNz {0}<{1!r}>format __class____name__rr/s r__repr__zListSchemasPager.__repr__X#""4>>#:#:DNNKKr N)r@ __module__ __qualname____doc__rr ListSchemasResponserrrstrrrr(propertyr r0Schemar8rArr rr r s./1 "f8889"**",, " 5c?+ "2---!x : :;!!$(6==1$L#Lr r c eZdZdZdddedeejfdejdejde e e e ffd Z d e d e fd Zed eejfd Zd eej$fdZd e fdZy)ListSchemasAsyncPageraA pager for iterating through ``list_schemas`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSchemasResponse` object, and provides an ``__aiter__`` method to iterate through its ``schemas`` field. If there are more pages, the ``__aiter__`` method will make additional ``ListSchemas`` requests and continue to iterate through the ``schemas`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSchemasResponse` attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup. rrr.rrrcb||_tj||_||_||_y)aInstantiates the pager. Args: method (Callable): The method that was originally called, and which instantiated this pager. request (google.pubsub_v1.types.ListSchemasRequest): The initial request object. response (google.pubsub_v1.types.ListSchemasResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Nrrs rrzListSchemasAsyncPager.__init__nrr r!r"c.t|j|Sr$r%r's rr(z!ListSchemasAsyncPager.__getattr__r)r cZK|j|jjr|jj|j_|j |j|j d{|_|j|jjryy71wr+r,r/s rr0zListSchemasAsyncPager.pagesnnnnn,,'+~~'E'EDMM $#'<< <#WWDN.. nn,,WA5B+7B)8.B+'B+cfd}|S)NclKj23d{}|jD]}|  76ywr$r4r7rrs rasync_generatorz8ListSchemasAsyncPager.__aiter__..async_generator0"jj #d $ H"N!- #j 4202424rrrTs` r __aiter__zListSchemasAsyncPager.__aiter__ #   r cbdj|jj|jSr<r=r/s rrAzListSchemasAsyncPager.__repr__rBr N)r@rCrDrErrr rFrrrrGrrr(rHrr0rIrXrArr rrKrK\s./1 "i(B(BCCD"**",, " 5c?+ "2---!]6+E+EF!!!=7!L#Lr rKc eZdZdZdddedej fdejdej dee e e ffd Z d e d e fd Z ed eej fd Zd eej"fdZd e fdZy)ListSchemaRevisionsPageraA pager for iterating through ``list_schema_revisions`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSchemaRevisionsResponse` object, and provides an ``__iter__`` method to iterate through its ``schemas`` field. If there are more pages, the ``__iter__`` method will make additional ``ListSchemaRevisions`` requests and continue to iterate through the ``schemas`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSchemaRevisionsResponse` attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup. rrr.rrrcb||_tj||_||_||_y)aInstantiate the pager. Args: method (Callable): The method that was originally called, and which instantiated this pager. request (google.pubsub_v1.types.ListSchemaRevisionsRequest): The initial request object. response (google.pubsub_v1.types.ListSchemaRevisionsResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Nrr ListSchemaRevisionsRequestrrrrs rrz!ListSchemaRevisionsPager.__init__+( 99'B !!r r!r"c.t|j|Sr$r%r's rr(z$ListSchemaRevisionsPager.__getattr__r)r c#BK|j|jjrw|jj|j_|j |j|j |_|j|jjrvyywr+r,r/s rr0zListSchemaRevisionsPager.pagesr1r2c#ZK|jD]}|jEd{y7wr$r4r6s rr8z!ListSchemaRevisionsPager.__iter__r9r:cbdj|jj|jSr<r=r/s rrAz!ListSchemaRevisionsPager.__repr__rBr N)r@rCrDrErr ListSchemaRevisionsResponser_rrrGrrr(rHr r0rIr8rArr rr\r\s./1 "f@@@A"22"44 " 5c?+ "2---!x B BC!!$(6==1$L#Lr r\c eZdZdZdddedeejfdejdejde e e e ffd Z d e d e fd Zed eejfd Zd eej$fdZd e fdZy)ListSchemaRevisionsAsyncPageraA pager for iterating through ``list_schema_revisions`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSchemaRevisionsResponse` object, and provides an ``__aiter__`` method to iterate through its ``schemas`` field. If there are more pages, the ``__aiter__`` method will make additional ``ListSchemaRevisions`` requests and continue to iterate through the ``schemas`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSchemaRevisionsResponse` attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup. rrr.rrrcb||_tj||_||_||_y)aInstantiates the pager. Args: method (Callable): The method that was originally called, and which instantiated this pager. request (google.pubsub_v1.types.ListSchemaRevisionsRequest): The initial request object. response (google.pubsub_v1.types.ListSchemaRevisionsResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Nr^rs rrz&ListSchemaRevisionsAsyncPager.__init__r`r r!r"c.t|j|Sr$r%r's rr(z)ListSchemaRevisionsAsyncPager.__getattr__r)r cZK|j|jjr|jj|j_|j |j|j d{|_|j|jjryy71wr+r,r/s rr0z#ListSchemaRevisionsAsyncPager.pages rOrPcfd}|S)NclKj23d{}|jD]}|  76ywr$r4rSs rrTz@ListSchemaRevisionsAsyncPager.__aiter__..async_generatorrUrVrrWs` rrXz'ListSchemaRevisionsAsyncPager.__aiter__rYr cbdj|jj|jSr<r=r/s rrAz&ListSchemaRevisionsAsyncPager.__repr__rBr N)r@rCrDrErrr rer_rrrGrrr(rHrr0rIrXrArr rrgrgs./1 "i(J(JKKL"22"44 " 5c?+ "2---!]6+M+MN!!!=7!L#Lr rgN)typingrrrrrrr r google.pubsub_v1.typesr r rKr\rgrr rrpsL   *;L;L|?L?LD;L;L|?L?Lr