
                             S SK Jr  S SKJrJr  S SKJr  S SKJr  S SK	J
r
  S SKrS SKJr  S\
S	\R                  4S
 jrS\
S	\R                  4S jrS	\4S jrg)    )	MagicMock)AbortedGoogleAPICallError)Any)	ErrorInfo)StatusN)
rpc_status	status_pbreturnc                    [         R                  " U 5      n[        [        R                  S9nUR
                  UR
                  l        UR                  UR                  l        UR                  UR                  l        U$ )N)spec)	r	   	to_statusr   grpcCalldetailsreturn_valuecodetrailing_metadata)r
   status	mock_calls      Dlib/third_party/google/cloud/pubsublite/testing/test_reset_signal.py	make_callr      s\    !!),Ftyy)I%+^^I""(++INN/5/G/GI,    c                 >    [        U 5      nS UR                  l        U$ )N)r   r   r   )r
   r   s     r   make_call_without_metadatar   !   s     )$I/3I,r   c                      [        5       n U R                  [        SSS95        [        SU /S9n[	        S[        U5      S9$ )NRESETzpubsublite.googleapis.com)reasondomain
   )r   r    )response)r   Packr   r   r   r   )anyr
   s     r   make_reset_signalr%   (   s=    
%CHHYg.IJKB.I2	) 455r   )unittest.mockr   google.api_core.exceptionsr   r    cloudsdk.google.protobuf.any_pb2r   google.rpc.error_details_pb2r   google.rpc.status_pb2r   r   grpc_statusr	   r   r   r   r%    r   r   <module>r-      sW    $ B 0 2 (  " DII & TYY 6- 6r   