
                         F    S SK Jr  S SKJr  S SKJr  S SKJr  S\S\4S jr	g)	    )GoogleAPICallError)is_retryable)	ErrorInfo)
status_pb2errorreturnc                    [        U 5      (       a  U R                  (       d  gU R                  nUR                  5       c  gUR                  5        H  u  p#US:X  d  M  [        R                  R                  U5      nUR                  5       R                  S   UR                  :w  d  UR                  5       UR                  :w  a    gUR                   Hp  nUR                  [        R                  5      (       d  M)  [        5       nUR                  U5      (       d  MK  UR                  S:X  d  M]  UR                  S:X  d  Mo      g   M     g)z
Determines whether the given error contains the stream RESET signal, sent by
the server to instruct clients to reset stream state.

Returns: True if the error contains the RESET signal.
Fzgrpc-status-details-binr   RESETzpubsublite.googleapis.comT)r   responsetrailing_metadatar   Status
FromStringcodevaluedetailsmessageIsr   
DESCRIPTORUnpackreasondomain)r   callkeyr   rich_statusdetailinfos          Elib/third_party/google/cloud/pubsublite/internal/wire/reset_signal.pyis_reset_signalr      s     enn>>D',,.
++$++66u=K		!!!$(8(88<<>[%8%88%--99Y1122$;Dd++ KK72 KK+FF# . /"     N)
google.api_core.exceptionsr   -google.cloud.pubsublite.internal.status_codesr   google.rpc.error_details_pb2r   
google.rpcr   boolr    r   r   <module>r&      s'    : F 2 !- $ r   