l)ddlmZmZmZmZmZmZmZmZddl m Z GddZ GddZ GddZ Gd d Zy ) )Any AsyncIterator AwaitableCallableSequenceTupleOptionalIterator)pubsubc eZdZdZdddedej fdejdej dee e e ffd Z d e d e fd Z ed eej fd Zd eej"fdZd e fdZy)ListSubscriptionsPageraA pager for iterating through ``list_subscriptions`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSubscriptionsResponse` object, and provides an ``__iter__`` method to iterate through its ``subscriptions`` field. If there are more pages, the ``__iter__`` method will make additional ``ListSubscriptions`` requests and continue to iterate through the ``subscriptions`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSubscriptionsResponse` 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.ListSubscriptionsRequest): The initial request object. response (google.pubsub_v1.types.ListSubscriptionsResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. N_methodr ListSubscriptionsRequest_request _response _metadataselfrrrrs >lib/third_party/google/pubsub_v1/services/subscriber/pagers.py__init__zListSubscriptionsPager.__init__0+( 77@ !!namereturnc.t|j|SNgetattrrrr!s r __getattr__z"ListSubscriptionsPager.__getattr__It~~t,,r c#BK|j|jjrw|jj|j_|j |j|j |_|j|jjrvyywNrrnext_page_tokenr page_tokenrrrs rpageszListSubscriptionsPager.pagesLhnnnn,,'+~~'E'EDMM $!\\$--$..\QDN.. nn,, BBBc#ZK|jD]}|jEd{y7wr$r0 subscriptionsrpages r__iter__zListSubscriptionsPager.__iter__Ts&JJD)) ) ) ) +)+cbdj|jj|jSNz {0}<{1!r}>format __class____name__rr/s r__repr__zListSubscriptionsPager.__repr__X#""4>>#:#:DNNKKr N)r? __module__ __qualname____doc__rr ListSubscriptionsResponserrrstrrrr(propertyr r0 Subscriptionr8r@rr rr r s./1 "f>>>?"00"22 " 5c?+ "2---!x @ @A!!*(6#6#67*L#Lr r c eZdZdZdddedeejfdejdejde e e e ffd Z d e d e fd Zed eejfd Zd eej$fdZd e fdZy)ListSubscriptionsAsyncPageraA pager for iterating through ``list_subscriptions`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSubscriptionsResponse` object, and provides an ``__aiter__`` method to iterate through its ``subscriptions`` field. If there are more pages, the ``__aiter__`` method will make additional ``ListSubscriptions`` requests and continue to iterate through the ``subscriptions`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSubscriptionsResponse` 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.ListSubscriptionsRequest): The initial request object. response (google.pubsub_v1.types.ListSubscriptionsResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Nrrs rrz$ListSubscriptionsAsyncPager.__init__nrr r!r"c.t|j|Sr$r%r's rr(z'ListSubscriptionsAsyncPager.__getattr__r)r cZK|j|jjr|jj|j_|j |j|j d{|_|j|jjryy71wr+r,r/s rr0z!ListSubscriptionsAsyncPager.pagesnnnnn,,'+~~'E'EDMM $#'<< <#WWDN.. nn,,WA5B+7B)8.B+'B+cfd}|S)NclKj23d{}|jD]}|  76ywr$r4r7rrs rasync_generatorz>ListSubscriptionsAsyncPager.__aiter__..async_generators2"jj #d $ 2 2H"N!3 #j 4202424rrrSs` r __aiter__z%ListSubscriptionsAsyncPager.__aiter__ #   r cbdj|jj|jSr;r<r/s rr@z$ListSubscriptionsAsyncPager.__repr__rAr N)r?rBrCrDrrr rErrrrFrrr(rGrr0rHrVr@rr rrJrJ\s./1 "i(H(HIIJ"00"22 " 5c?+ "2---!]6+K+KL!!!=)<)<=!L#Lr rJc eZdZdZdddedej fdejdej dee e e ffd Z d e d e fd Z ed eej fd Zd eej"fdZd e fdZy)ListSnapshotsPageraA pager for iterating through ``list_snapshots`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSnapshotsResponse` object, and provides an ``__iter__`` method to iterate through its ``snapshots`` field. If there are more pages, the ``__iter__`` method will make additional ``ListSnapshots`` requests and continue to iterate through the ``snapshots`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSnapshotsResponse` 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)a Instantiate the pager. Args: method (Callable): The method that was originally called, and which instantiated this pager. request (google.pubsub_v1.types.ListSnapshotsRequest): The initial request object. response (google.pubsub_v1.types.ListSnapshotsResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Nrr ListSnapshotsRequestrrrrs rrzListSnapshotsPager.__init__+( 33G< !!r r!r"c.t|j|Sr$r%r's rr(zListSnapshotsPager.__getattr__r)r c#BK|j|jjrw|jj|j_|j |j|j |_|j|jjrvyywr+r,r/s rr0zListSnapshotsPager.pagesr1r2c#ZK|jD]}|jEd{y7wr$r0 snapshotsr6s rr8zListSnapshotsPager.__iter__s$JJD~~ % % %r9cbdj|jj|jSr;r<r/s rr@zListSnapshotsPager.__repr__rAr N)r?rBrCrDrr ListSnapshotsResponser]rrrFrrr(rGr r0Snapshotr8r@rr rrZrZs./1 "f:::;",,".. " 5c?+ "2---!x < <=!!&(6??3&L#Lr rZc eZdZdZdddedeejfdejdejde e e e ffd Z d e d e fd Zed eejfd Zd eej$fdZd e fdZy)ListSnapshotsAsyncPageraA pager for iterating through ``list_snapshots`` requests. This class thinly wraps an initial :class:`google.pubsub_v1.types.ListSnapshotsResponse` object, and provides an ``__aiter__`` method to iterate through its ``snapshots`` field. If there are more pages, the ``__aiter__`` method will make additional ``ListSnapshots`` requests and continue to iterate through the ``snapshots`` field on the corresponding responses. All the usual :class:`google.pubsub_v1.types.ListSnapshotsResponse` 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)a Instantiates the pager. Args: method (Callable): The method that was originally called, and which instantiated this pager. request (google.pubsub_v1.types.ListSnapshotsRequest): The initial request object. response (google.pubsub_v1.types.ListSnapshotsResponse): The initial response object. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Nr\rs rrz ListSnapshotsAsyncPager.__init__r^r r!r"c.t|j|Sr$r%r's rr(z#ListSnapshotsAsyncPager.__getattr__r)r cZK|j|jjr|jj|j_|j |j|j d{|_|j|jjryy71wr+r,r/s rr0zListSnapshotsAsyncPager.pages rNrOcfd}|S)NclKj23d{}|jD]}|  76ywr$rbrRs rrSz:ListSnapshotsAsyncPager.__aiter__..async_generators0"jj #d $H"N!/ #jrTrrUs` rrVz!ListSnapshotsAsyncPager.__aiter__rWr cbdj|jj|jSr;r<r/s rr@z ListSnapshotsAsyncPager.__repr__rAr N)r?rBrCrDrrr rer]rrrFrrr(rGrr0rfrVr@rr rrhrhs./1 "i(D(DEEF",,".. " 5c?+ "2---!]6+G+GH!!!=9!L#Lr rhN)typingrrrrrrr r google.pubsub_v1.typesr r rJrZrhrr rrqsL   *;L;L|?L?LD;L;L|?L?Lr