
    .)                         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)schemac                   
   \ 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)ListSchemasPager   au  A 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.
 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.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	_metadataselfr   r   r   r   s        Blib/third_party/google/pubsub_v1/services/schema_service/pagers.py__init__ListSchemasPager.__init__0   %    ( 11':!!    namereturnc                 .    [        U R                  U5      $ Ngetattrr   r   r#   s     r   __getattr__ListSchemasPager.__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ListSchemasPager.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   schemasr   pages     r   __iter__ListSchemasPager.__iter__T   #     JJD||## #   -+
-c                 b    SR                  U R                  R                  U R                  5      $ Nz
{0}<{1!r}>format	__class____name__r   r2   s    r   __repr__ListSchemasPager.__repr__X   #    ""4>>#:#:DNNKKr"   r   r   r   r   N)rE   
__module____qualname____firstlineno____doc__r   r   ListSchemasResponser   r   r   strr   r   r*   propertyr
   r3   Schemar<   rF   __static_attributes__r   r"   r   r   r      s    . /1"f8889" **" ,,	" 5c?+"2- - - !x : :; ! !$(6==1 $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)ListSchemasAsyncPager\   aw  A 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.
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.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.
Nr   r   s        r   r   ListSchemasAsyncPager.__init__n   r!   r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   !ListSchemasAsyncPager.__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   ListSchemasAsyncPager.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_generator8ListSchemasAsyncPager.__aiter__.<locals>.async_generator   .     "jj #d $H"N !-#j   7535757r   r   ra   s   ` r   	__aiter__ListSchemasAsyncPager.__aiter__       	#
   r"   c                 b    SR                  U R                  R                  U R                  5      $ rA   rB   r2   s    r   rF   ListSchemasAsyncPager.__repr__   rH   r"   rI   N)rE   rJ   rK   rL   rM   r   r   r   rN   r   r   r   rO   r   r   r*   rP   r   r3   rQ   rf   rF   rR   r   r"   r   rT   rT   \   s    . /1"i(B(BCCD" **" ,,	" 5c?+"2- - - !]6+E+EF ! !!=7 !L# Lr"   rT   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)ListSchemaRevisionsPager   a  A 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.
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.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.
Nr   r   ListSchemaRevisionsRequestr   r   r   r   s        r   r   !ListSchemaRevisionsPager.__init__   %    ( 99'B!!r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   $ListSchemaRevisionsPager.__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   ListSchemaRevisionsPager.pages   r5   r6   c              #   ^   #    U R                    H  nUR                   S h  vN   M     g  N	7fr&   r8   r:   s     r   r<   !ListSchemaRevisionsPager.__iter__   r>   r?   c                 b    SR                  U R                  R                  U R                  5      $ rA   rB   r2   s    r   rF   !ListSchemaRevisionsPager.__repr__   rH   r"   rI   N)rE   rJ   rK   rL   rM   r   r   ListSchemaRevisionsResponserp   r   r   rO   r   r   r*   rP   r
   r3   rQ   r<   rF   rR   r   r"   r   rl   rl      s    . /1"f@@@A" 22" 44	" 5c?+"2- - - !x B BC ! !$(6==1 $L# Lr"   rl   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)ListSchemaRevisionsAsyncPager   a  A 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.
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.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.
Nro   r   s        r   r   &ListSchemaRevisionsAsyncPager.__init__   rr   r"   r#   r$   c                 .    [        U R                  U5      $ r&   r'   r)   s     r   r*   )ListSchemaRevisionsAsyncPager.__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   #ListSchemaRevisionsAsyncPager.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&   r8   r`   s     r   ra   @ListSchemaRevisionsAsyncPager.__aiter__.<locals>.async_generator  rc   rd   r   re   s   ` r   rf   'ListSchemaRevisionsAsyncPager.__aiter__  rh   r"   c                 b    SR                  U R                  R                  U R                  5      $ rA   rB   r2   s    r   rF   &ListSchemaRevisionsAsyncPager.__repr__  rH   r"   rI   N)rE   rJ   rK   rL   rM   r   r   r   r{   rp   r   r   rO   r   r   r*   rP   r   r3   rQ   rf   rF   rR   r   r"   r   r}   r}      s    . /1"i(J(JKKL" 22" 44	" 5c?+"2- - - !]6+M+MN ! !!=7 !L# Lr"   r}   N)typingr   r   r   r   r   r   r	   r
   google.pubsub_v1.typesr   r   rT   rl   r}   r   r"   r   <module>r      sL    	 	 	 *;L ;L|?L ?LD;L ;L|?L ?Lr"   