
    <                         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 " 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)ListTopicsPager   ao  A pager for iterating through ``list_topics`` requests.

This class thinly wraps an initial
:class:`google.pubsub_v1.types.ListTopicsResponse` object, and
provides an ``__iter__`` method to iterate through its
``topics`` field.

If there are more pages, the ``__iter__`` method will make additional
``ListTopics`` requests and continue to iterate
through the ``topics`` field on the
corresponding responses.

All the usual :class:`google.pubsub_v1.types.ListTopicsResponse`
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.ListTopicsRequest):
        The initial request object.
    response (google.pubsub_v1.types.ListTopicsResponse):
        The initial response object.
    metadata (Sequence[Tuple[str, str]]): Strings which should be
        sent along with the request as metadata.
N_methodr   ListTopicsRequest_request	_response	_metadataselfr   r   r   r   s        =lib/third_party/google/pubsub_v1/services/publisher/pagers.py__init__ListTopicsPager.__init__0   %    ( 009!!    namereturnc                 .    [        U R                  U5      $ Ngetattrr   r   r#   s     r   __getattr__ListTopicsPager.__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ListTopicsPager.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   topicsr   pages     r   __iter__ListTopicsPager.__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__ListTopicsPager.__repr__X   #    ""4>>#:#:DNNKKr"   r   r   r   r   N)rD   
__module____qualname____firstlineno____doc__r   r   ListTopicsResponser   r   r   strr   r   r*   propertyr
   r3   Topicr<   rE   __static_attributes__r   r"   r   r   r      s    . /1"f7778" ))" ++	" 5c?+"2- - - !x 9 9: ! !#(6<<0 #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)ListTopicsAsyncPager\   aq  A pager for iterating through ``list_topics`` requests.

This class thinly wraps an initial
:class:`google.pubsub_v1.types.ListTopicsResponse` object, and
provides an ``__aiter__`` method to iterate through its
``topics`` field.

If there are more pages, the ``__aiter__`` method will make additional
``ListTopics`` requests and continue to iterate
through the ``topics`` field on the
corresponding responses.

All the usual :class:`google.pubsub_v1.types.ListTopicsResponse`
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.ListTopicsRequest):
        The initial request object.
    response (google.pubsub_v1.types.ListTopicsResponse):
        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   ListTopicsAsyncPager.__init__n   r!   r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*    ListTopicsAsyncPager.__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   ListTopicsAsyncPager.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_generator7ListTopicsAsyncPager.__aiter__.<locals>.async_generator   s.     "jj #d $H"N !,#j   7535757r   r   r`   s   ` r   	__aiter__ListTopicsAsyncPager.__aiter__       	#
   r"   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE   ListTopicsAsyncPager.__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(A(ABBC" ))" ++	" 5c?+"2- - - !]6+D+DE ! !!=6 !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\\   4S jrS\4S jrSrg)ListTopicSubscriptionsPager   a  A pager for iterating through ``list_topic_subscriptions`` requests.

This class thinly wraps an initial
:class:`google.pubsub_v1.types.ListTopicSubscriptionsResponse` object, and
provides an ``__iter__`` method to iterate through its
``subscriptions`` field.

If there are more pages, the ``__iter__`` method will make additional
``ListTopicSubscriptions`` requests and continue to iterate
through the ``subscriptions`` field on the
corresponding responses.

All the usual :class:`google.pubsub_v1.types.ListTopicSubscriptionsResponse`
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.ListTopicSubscriptionsRequest):
        The initial request object.
    response (google.pubsub_v1.types.ListTopicSubscriptionsResponse):
        The initial response object.
    metadata (Sequence[Tuple[str, str]]): Strings which should be
        sent along with the request as metadata.
Nr   r   ListTopicSubscriptionsRequestr   r   r   r   s        r   r   $ListTopicSubscriptionsPager.__init__   %    ( <<WE!!r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   'ListTopicSubscriptionsPager.__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   !ListTopicSubscriptionsPager.pages   r5   r6   c              #   ^   #    U R                    H  nUR                   S h  vN   M     g  N	7fr&   r3   subscriptionsr:   s     r   r<   $ListTopicSubscriptionsPager.__iter__   s%     JJD)))) )r>   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE   $ListTopicSubscriptionsPager.__repr__   rG   r"   rH   N)rD   rI   rJ   rK   rL   r   r   ListTopicSubscriptionsResponsern   r   r   rN   r   r   r*   rO   r
   r3   r<   rE   rQ   r   r"   r   rj   rj      s    . /1"fCCCD" 55" 77	" 5c?+"2- - - !x E EF ! !*(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\\   4S jrS\4S jrSrg) ListTopicSubscriptionsAsyncPager   a  A pager for iterating through ``list_topic_subscriptions`` requests.

This class thinly wraps an initial
:class:`google.pubsub_v1.types.ListTopicSubscriptionsResponse` object, and
provides an ``__aiter__`` method to iterate through its
``subscriptions`` field.

If there are more pages, the ``__aiter__`` method will make additional
``ListTopicSubscriptions`` requests and continue to iterate
through the ``subscriptions`` field on the
corresponding responses.

All the usual :class:`google.pubsub_v1.types.ListTopicSubscriptionsResponse`
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.ListTopicSubscriptionsRequest):
        The initial request object.
    response (google.pubsub_v1.types.ListTopicSubscriptionsResponse):
        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   )ListTopicSubscriptionsAsyncPager.__init__   rp   r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   ,ListTopicSubscriptionsAsyncPager.__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   &ListTopicSubscriptionsAsyncPager.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`   CListTopicSubscriptionsAsyncPager.__aiter__.<locals>.async_generator  s0     "jj #d $ 2 2H"N !3#jrb   r   rc   s   ` r   rd   *ListTopicSubscriptionsAsyncPager.__aiter__  rf   r"   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE   )ListTopicSubscriptionsAsyncPager.__repr__  rG   r"   rH   N)rD   rI   rJ   rK   rL   r   r   r   r{   rn   r   r   rN   r   r   r*   rO   r   r3   rd   rE   rQ   r   r"   r   r}   r}      s    . /1"i(M(MNNO" 55" 77	" 5c?+"2- - - !]6+P+PQ ! !!=- !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\\   4S jrS\4S jrSrg)ListTopicSnapshotsPageri  a  A pager for iterating through ``list_topic_snapshots`` requests.

This class thinly wraps an initial
:class:`google.pubsub_v1.types.ListTopicSnapshotsResponse` object, and
provides an ``__iter__`` method to iterate through its
``snapshots`` field.

If there are more pages, the ``__iter__`` method will make additional
``ListTopicSnapshots`` requests and continue to iterate
through the ``snapshots`` field on the
corresponding responses.

All the usual :class:`google.pubsub_v1.types.ListTopicSnapshotsResponse`
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.ListTopicSnapshotsRequest):
        The initial request object.
    response (google.pubsub_v1.types.ListTopicSnapshotsResponse):
        The initial response object.
    metadata (Sequence[Tuple[str, str]]): Strings which should be
        sent along with the request as metadata.
Nr   r   ListTopicSnapshotsRequestr   r   r   r   s        r   r    ListTopicSnapshotsPager.__init__0  %    ( 88A!!r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   #ListTopicSnapshotsPager.__getattr__I  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   ListTopicSnapshotsPager.pagesL  r5   r6   c              #   ^   #    U R                    H  nUR                   S h  vN   M     g  N	7fr&   r3   	snapshotsr:   s     r   r<    ListTopicSnapshotsPager.__iter__T  s#     JJD~~%% %r>   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE    ListTopicSnapshotsPager.__repr__X  rG   r"   rH   N)rD   rI   rJ   rK   rL   r   r   ListTopicSnapshotsResponser   r   r   rN   r   r   r*   rO   r
   r3   r<   rE   rQ   r   r"   r   r   r     s    . /1"f???@" 11" 33	" 5c?+"2- - - !x A AB ! !&(3- &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\\   4S jrS\4S jrSrg)ListTopicSnapshotsAsyncPageri\  a  A pager for iterating through ``list_topic_snapshots`` requests.

This class thinly wraps an initial
:class:`google.pubsub_v1.types.ListTopicSnapshotsResponse` object, and
provides an ``__aiter__`` method to iterate through its
``snapshots`` field.

If there are more pages, the ``__aiter__`` method will make additional
``ListTopicSnapshots`` requests and continue to iterate
through the ``snapshots`` field on the
corresponding responses.

All the usual :class:`google.pubsub_v1.types.ListTopicSnapshotsResponse`
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.ListTopicSnapshotsRequest):
        The initial request object.
    response (google.pubsub_v1.types.ListTopicSnapshotsResponse):
        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   %ListTopicSnapshotsAsyncPager.__init__n  r   r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   (ListTopicSnapshotsAsyncPager.__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   "ListTopicSnapshotsAsyncPager.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&   r   r_   s     r   r`   ?ListTopicSnapshotsAsyncPager.__aiter__.<locals>.async_generator  s.     "jj #d $H"N !/#jrb   r   rc   s   ` r   rd   &ListTopicSnapshotsAsyncPager.__aiter__  rf   r"   c                 b    SR                  U R                  R                  U R                  5      $ r@   rA   r2   s    r   rE   %ListTopicSnapshotsAsyncPager.__repr__  rG   r"   rH   N)rD   rI   rJ   rK   rL   r   r   r   r   r   r   r   rN   r   r   r*   rO   r   r3   rd   rE   rQ   r   r"   r   r   r   \  s    . /1"i(I(IJJK" 11" 33	" 5c?+"2- - - !]6+L+LM ! !!=- !L# Lr"   r   N)typingr   r   r   r   r   r   r	   r
   google.pubsub_v1.typesr   r   rS   rj   r}   r   r   r   r"   r   <module>r      sf    	 	 	 *;L ;L|?L ?LD;L ;L|?L ?LD;L ;L|?L ?Lr"   