
    ZTh                         d dl mZmZ d dlmZmZmZmZ d dlZd dl	m
Z d dl	mZ d dlmZ eegef   Zeegef   Zeegdf   Zeeef   ZeZ G d de      Z G d de      Zy)	    )AsyncIterableIterable)AnyCallableOptionalUnionN)Channelc                       e Zd ZdZd Zd Zd Zd ZddZd Z		 	 	 dd	Z
	 	 	 dd
Z	 	 	 ddZ	 	 	 ddZd Zd Zd Zy)MockChannelz%
    Used as a mock gRPC channel
    c                      y N selfmethod_descriptors     h/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_py/_internal/test_util/channel.pytake_unary_unaryzMockChannel.take_unary_unary           c                      y r   r   r   s     r   take_unary_streamzMockChannel.take_unary_stream   r   r   c                      y r   r   r   s     r   take_stream_unaryzMockChannel.take_stream_unary   r   r   c                      y r   r   r   s     r   take_stream_streamzMockChannel.take_stream_stream   r   r   c                      y r   r   )r   callbacktry_to_connects      r   	subscribezMockChannel.subscribe!   r   r   c                      y r   r   )r   r   s     r   unsubscribezMockChannel.unsubscribe$   r   r   Nc                      y r   r   r   methodrequest_serializerresponse_deserializer_registered_methods        r   unary_unaryzMockChannel.unary_unary'        	r   c                      y r   r   r#   s        r   unary_streamzMockChannel.unary_stream0   r)   r   c                      y r   r   r#   s        r   stream_unaryzMockChannel.stream_unary9   r)   r   c                      y r   r   r#   s        r   stream_streamzMockChannel.stream_streamB   r)   r   c                      y r   r   r   s    r   closezMockChannel.closeK   r   r   c                      y r   r   r1   s    r   	__enter__zMockChannel.__enter__N   r   r   c                      y r   r   r   exc_typeexc_valexc_tbs       r   __exit__zMockChannel.__exit__Q   r   r   FNNF)__name__
__module____qualname____doc__r   r   r   r   r   r!   r(   r+   r-   r/   r2   r4   r:   r   r   r   r   r      st      "   "   "   " r   r   c                      e Zd Zd Zd Zddee   fdZddede	j                  fdZd	e	j                  ddfd
ZddZ	 	 	 ddedee   dee   dee   dej$                  f
dZ	 	 	 ddedee   dee   dee   dej(                  f
dZ	 	 	 ddedee   dee   dee   dej,                  f
dZ	 	 	 ddedee   dee   dee   dej0                  f
dZy)MockAsyncChannelc                    K   y wr   r   r1   s    r   
__aenter__zMockAsyncChannel.__aenter__V   	        c                    K   y wr   r   r6   s       r   	__aexit__zMockAsyncChannel.__aexit__Y   rE   rF   Ngracec                    K   y wr   r   )r   rI   s     r   r2   zMockAsyncChannel.close\   rE   rF   r   returnc                      y r   r   )r   r   s     r   	get_statezMockAsyncChannel.get_state_   s    r   last_observed_statec                    K   y wr   r   )r   rN   s     r   wait_for_state_changez&MockAsyncChannel.wait_for_state_changea   s      rF   c                    K   y wr   r   r1   s    r   channel_readyzMockAsyncChannel.channel_readyg   s	     rF   r$   r%   r&   r'   c                      y r   r   r#   s        r   r(   zMockAsyncChannel.unary_unaryj   s     ,/r   c                      y r   r   r#   s        r   r+   zMockAsyncChannel.unary_streamr        -0r   c                      y r   r   r#   s        r   r-   zMockAsyncChannel.stream_unaryz   rU   r   c                      y r   r   r#   s        r   r/   zMockAsyncChannel.stream_stream   s     .1r   r   r;   )rK   Nr<   )r=   r>   r?   rD   rH   r   floatr2   boolgrpcChannelConnectivityrM   rP   rR   strSerializingFunctionDeserializingFunctiongrpc_aioUnaryUnaryMultiCallabler(   UnaryStreamMultiCallabler+   StreamUnaryMultiCallabler-   StreamStreamMultiCallabler/   r   r   r   rB   rB   U   s   %  WV9Q9QV!55 
 =AAE-2// %%89/  ((=>	/
 %TN/ 
	)	)/ =AAE-200 %%890  ((=>	0
 %TN0 
	*	*0 =AAE-200 %%890  ((=>	0
 %TN0 
	*	*0 =AAE-211 %%891  ((=>	1
 %TN1 
	+	+1r   rB   )collections.abcr   r   typingr   r   r   r   rZ   grpc.aioaior_   r	   AsyncChannelgrpc_testingbytesr]   r^   DoneCallbackTypeRequestIterableTypeResponseIterableTyper   rB   r   r   r   <module>rn      s~    3 1 1   ,  ue|,  %#. SE4K( Hm34 $ B' BJ31| 31r   