
    l)                         S SK JrJrJrJrJrJrJrJr  S SK	J
r
   " S S5      r " S S5      r " S S5      r " S	 S
5      rg)    )AnyAsyncIterator	AwaitableCallableSequenceTupleOptionalIterator)pubsubc                   
   \ rS rSrSrSS.S\S\R                  4   S\R                  S\R                  S	\	\
\\4      4S
 jjrS\S\4S jr\S\\R                     4S j5       rS\\R$                     4S jrS\4S jrSrg)ListSubscriptionsPager   a  A 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method.requestresponser   c                ^    Xl         [        R                  " U5      U l        X0l        X@l        g)a  Instantiate 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	_metadataselfr   r   r   r   s        >lib/third_party/google/pubsub_v1/services/subscriber/pagers.py__init__ListSubscriptionsPager.__init__0   %    ( 77@!!    namereturnc                 .    [        U R                  U5      $ Ngetattrr   r   r#   s     r   __getattr__"ListSubscriptionsPager.__getattr__I       t~~t,,r"   c              #   R  #    U R                   v   U R                   R                  (       az  U R                   R                  U R                  l        U R	                  U R                  U R
                  S9U l         U R                   v   U R                   R                  (       a  My  g g 7fNr   r   next_page_tokenr   
page_tokenr   r   r   s    r   pagesListSubscriptionsPager.pagesL   j     nnnn,,'+~~'E'EDMM$!\\$--$..\QDN..  nn,,,   B!B'%B'c              #   ^   #    U R                    H  nUR                   S h  vN   M     g  N	7fr&   r3   subscriptionsr   pages     r   __iter__ListSubscriptionsPager.__iter__T   s%     JJD)))) )   -+
-c                 b    SR                  U R                  R                  U R                  5      $ Nz
{0}<{1!r}>format	__class____name__r   r2   s    r   __repr__ListSubscriptionsPager.__repr__X   #    ""4>>#:#:DNNKKr"   r   r   r   r   N)rD   
__module____qualname____firstlineno____doc__r   r   ListSubscriptionsResponser   r   r   strr   r   r*   propertyr
   r3   Subscriptionr<   rE   __static_attributes__r   r"   r   r   r      s    . /1"f>>>?" 00" 22	" 5c?+"2- - - !x @ @A ! !*(6#6#67 *L# Lr"   r   c                      \ rS rSrSrSS.S\S\\R                     4   S\R                  S\R                  S	\
\\\4      4S
 jjrS\S\4S jr\S\\R                     4S j5       rS\\R&                     4S jrS\4S jrSrg)ListSubscriptionsAsyncPager\   a  A 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   r   .r   r   r   c                ^    Xl         [        R                  " U5      U l        X0l        X@l        g)a  Instantiates 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.
Nr   r   s        r   r   $ListSubscriptionsAsyncPager.__init__n   r!   r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   'ListSubscriptionsAsyncPager.__getattr__   r,   r"   c                j  #    U R                   7v   U R                   R                  (       a  U R                   R                  U R                  l        U R	                  U R                  U R
                  S9I S h  vN U l         U R                   7v   U R                   R                  (       a  M  g g  N77fr.   r/   r2   s    r   r3   !ListSubscriptionsAsyncPager.pages   p     nnnn,,'+~~'E'EDMM$#'<<<#WWDN..  nn,,,W   A7B39B1:3B3/B3c                    ^  U 4S jnU" 5       $ )Nc                 r   >#    TR                     S h  vN n U R                   H  nU7v   M
     M#   N
 g 7fr&   r8   r;   r   r   s     r   async_generator>ListSubscriptionsAsyncPager.__aiter__.<locals>.async_generator   s0     "jj #d $ 2 2H"N !3#j   7535757r   r   r`   s   ` r   	__aiter__%ListSubscriptionsAsyncPager.__aiter__       	#
   r"   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE   $ListSubscriptionsAsyncPager.__repr__   rG   r"   rH   N)rD   rI   rJ   rK   rL   r   r   r   rM   r   r   r   rN   r   r   r*   rO   r   r3   rP   rd   rE   rQ   r   r"   r   rS   rS   \   s    . /1"i(H(HIIJ" 00" 22	" 5c?+"2- - - !]6+K+KL ! !!=)<)<= !L# Lr"   rS   c                   
   \ rS rSrSrSS.S\S\R                  4   S\R                  S\R                  S	\	\
\\4      4S
 jjrS\S\4S jr\S\\R                     4S j5       rS\\R$                     4S jrS\4S jrSrg)ListSnapshotsPager   a  A 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   r   .r   r   r   c                ^    Xl         [        R                  " U5      U l        X0l        X@l        g)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.
Nr   r   ListSnapshotsRequestr   r   r   r   s        r   r   ListSnapshotsPager.__init__   %    ( 33G<!!r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   ListSnapshotsPager.__getattr__   r,   r"   c              #   R  #    U R                   v   U R                   R                  (       az  U R                   R                  U R                  l        U R	                  U R                  U R
                  S9U l         U R                   v   U R                   R                  (       a  My  g g 7fr.   r/   r2   s    r   r3   ListSnapshotsPager.pages   r5   r6   c              #   ^   #    U R                    H  nUR                   S h  vN   M     g  N	7fr&   r3   	snapshotsr:   s     r   r<   ListSnapshotsPager.__iter__   s#     JJD~~%% %r>   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE   ListSnapshotsPager.__repr__   rG   r"   rH   N)rD   rI   rJ   rK   rL   r   r   ListSnapshotsResponsern   r   r   rN   r   r   r*   rO   r
   r3   Snapshotr<   rE   rQ   r   r"   r   rj   rj      s    . /1"f:::;" ,," ..	" 5c?+"2- - - !x < <= ! !&(6??3 &L# Lr"   rj   c                      \ rS rSrSrSS.S\S\\R                     4   S\R                  S\R                  S	\
\\\4      4S
 jjrS\S\4S jr\S\\R                     4S j5       rS\\R&                     4S jrS\4S jrSrg)ListSnapshotsAsyncPager   a  A 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   r   .r   r   r   c                ^    Xl         [        R                  " U5      U l        X0l        X@l        g)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.
Nrm   r   s        r   r    ListSnapshotsAsyncPager.__init__   rp   r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   #ListSnapshotsAsyncPager.__getattr__  r,   r"   c                j  #    U R                   7v   U R                   R                  (       a  U R                   R                  U R                  l        U R	                  U R                  U R
                  S9I S h  vN U l         U R                   7v   U R                   R                  (       a  M  g g  N77fr.   r/   r2   s    r   r3   ListSnapshotsAsyncPager.pages
  r[   r\   c                    ^  U 4S jnU" 5       $ )Nc                 r   >#    TR                     S h  vN n U R                   H  nU7v   M
     M#   N
 g 7fr&   rv   r_   s     r   r`   :ListSnapshotsAsyncPager.__aiter__.<locals>.async_generator  s.     "jj #d $H"N !/#jrb   r   rc   s   ` r   rd   !ListSnapshotsAsyncPager.__aiter__  rf   r"   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE    ListSnapshotsAsyncPager.__repr__  rG   r"   rH   N)rD   rI   rJ   rK   rL   r   r   r   r{   rn   r   r   rN   r   r   r*   rO   r   r3   r|   rd   rE   rQ   r   r"   r   r~   r~      s    . /1"i(D(DEEF" ,," ..	" 5c?+"2- - - !]6+G+GH ! !!=9 !L# Lr"   r~   N)typingr   r   r   r   r   r   r	   r
   google.pubsub_v1.typesr   r   rS   rj   r~   r   r"   r   <module>r      sL    	 	 	 *;L ;L|?L ?LD;L ;L|?L ?Lr"   