a !fl)@spddlmZmZmZmZmZmZmZmZddl m Z GdddZ GdddZ GdddZ Gd d d Zd S) )Any AsyncIterator AwaitableCallableSequenceTupleOptionalIterator)pubsubc@seZdZdZddedejfejejee e e fdddZ e e dd d Z eeejd d d Zeejd ddZe d ddZdS)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. metadata.methodrequestresponsercCs"||_t||_||_||_dS)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 _metadataselfrrrrr r l/var/www/html/python-backend/venv/lib/python3.9/site-packages/google/pubsub_v1/services/subscriber/pagers.py__init__0s zListSubscriptionsPager.__init__namereturncCs t|j|SNgetattrrrrr r r __getattr__Isz"ListSubscriptionsPager.__getattr__rccs>|jV|jjr:|jj|j_|j|j|jd|_|jVqdSNr rZnext_page_tokenrZ page_tokenrrrr r rpagesLs  zListSubscriptionsPager.pagesccs|jD]}|jEdHqdSr r)Z subscriptionsrpager r r__iter__Ts zListSubscriptionsPager.__iter__cCsd|jj|jSNz {0}<{1!r}>format __class____name__rr(r r r__repr__XszListSubscriptionsPager.__repr__N)r2 __module__ __qualname____doc__rr ListSubscriptionsResponserrrstrrrr$propertyr r) Subscriptionr-r3r r r rr s  r c@seZdZdZddedeejfejeje e e e fdddZ e e dd d Zeeejd d d Zeejd ddZe d ddZdS)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. r r .rcCs"||_t||_||_||_dS)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. Nrrr r rrns z$ListSubscriptionsAsyncPager.__init__rcCs t|j|Sr r!r#r r rr$sz'ListSubscriptionsAsyncPager.__getattr__r%cCsD|jV|jjr@|jj|j_|j|j|jdIdH|_|jVqdSr&r'r(r r rr)s  z!ListSubscriptionsAsyncPager.pagescsfdd}|S)Ncs,j2z3dHW}|jD] }|Vqq6dSr r*r,rr(r rasync_generators z>ListSubscriptionsAsyncPager.__aiter__..async_generatorr rr=r r(r __aiter__s z%ListSubscriptionsAsyncPager.__aiter__cCsd|jj|jSr.r/r(r r rr3sz$ListSubscriptionsAsyncPager.__repr__N)r2r4r5r6rrr r7rrrr8rrr$r9rr)r:r?r3r r r rr;\s r;c@seZdZdZddedejfejejee e e fdddZ e e dd d Z eeejd d d Zeejd ddZe d ddZdS)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. r r .rcCs"||_t||_||_||_dS)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 ListSnapshotsRequestrrrrr r rrs zListSnapshotsPager.__init__rcCs t|j|Sr r!r#r r rr$szListSnapshotsPager.__getattr__r%ccs>|jV|jjr:|jj|j_|j|j|jd|_|jVqdSr&r'r(r r rr)s  zListSnapshotsPager.pagesccs|jD]}|jEdHqdSr r)Z snapshotsr+r r rr-s zListSnapshotsPager.__iter__cCsd|jj|jSr.r/r(r r rr3szListSnapshotsPager.__repr__N)r2r4r5r6rr ListSnapshotsResponserBrrr8rrr$r9r r)Snapshotr-r3r r r rr@s  r@c@seZdZdZddedeejfejeje e e e fdddZ e e dd d Zeeejd d d Zeejd ddZe d ddZdS)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. r r .rcCs"||_t||_||_||_dS)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. NrArr r rrs z ListSnapshotsAsyncPager.__init__rcCs t|j|Sr r!r#r r rr$sz#ListSnapshotsAsyncPager.__getattr__r%cCsD|jV|jjr@|jj|j_|j|j|jdIdH|_|jVqdSr&r'r(r r rr) s  zListSnapshotsAsyncPager.pagescsfdd}|S)Ncs,j2z3dHW}|jD] }|Vqq6dSr rCr<r(r rr=s z:ListSnapshotsAsyncPager.__aiter__..async_generatorr r>r r(rr?s z!ListSnapshotsAsyncPager.__aiter__cCsd|jj|jSr.r/r(r r rr3sz ListSnapshotsAsyncPager.__repr__N)r2r4r5r6rrr rDrBrrr8rrr$r9rr)rEr?r3r r r rrFs rFN)typingrrrrrrrr Zgoogle.pubsub_v1.typesr r r;r@rFr r r rs ( >B>