o ©çˆb<ã@sšdZddlZddlZddlZddlZddlZddlmZddlZe e ¡Z dZGdd„de dd¡ej ƒZ Gd d „d ejƒZGdd„dejƒZd d„ZdS)z#Internal utilities for gRPC Python.éN)Ú_commonz6Exception calling connectivity future "done" callback!c@seZdZdS)ÚRpcMethodHandlerN)Ú__name__Ú __module__Ú__qualname__©rrú/lib/python3.10/site-packages/grpc/_utilities.pyrsrZ_RpcMethodHandler)Zrequest_streamingZresponse_streamingZrequest_deserializerZresponse_serializerZunary_unaryZunary_streamZstream_unaryZ stream_streamc@s$eZdZdd„Zdd„Zdd„ZdS)ÚDictionaryGenericHandlercs$ˆ|_‡fdd„t |¡Dƒ|_dS)Ncsi|]\}}t ˆ|¡|“qSr)rZfully_qualified_method)Ú.0ÚmethodZmethod_handler©ÚservicerrÚ 1sÿÿz5DictionaryGenericHandler.__init__..)Ú_nameÚsixZ iteritemsÚ_method_handlers)Úselfr Zmethod_handlersrrrÚ__init__/s þz!DictionaryGenericHandler.__init__cCs|jS©N)r©rrrrÚservice_name6sz%DictionaryGenericHandler.service_namecCs|j |j¡Sr)rÚgetr)rZhandler_call_detailsrrrr 9óz DictionaryGenericHandler.serviceN)rrrrrr rrrrr -sr c@szeZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z ddd„Z ddd„Zddd„Zdd„Z dd„Zdd„ZdS)Ú_ChannelReadyFuturecCs&t ¡|_||_d|_d|_g|_dS)NF)Ú threadingZ ConditionÚ _conditionÚ_channelÚ_maturedÚ _cancelledÚ_done_callbacks)rÚchannelrrrr?s z_ChannelReadyFuture.__init__cCsœ|durdnt ¡|}|j5 |jrt ¡‚|jr$ WdƒdS|dur.|j ¡n|t ¡}|dkr|j|jj|jddWdƒdS1swYdS)NT)Ztry_to_connect)rrZ subscriber'rrrrÚstart›s"ÿz_ChannelReadyFuture.startcCsf|j&|js|js!|j |j¡WdƒdSWdƒdSWdƒdS1s,wYdSr)rrrrr&r'rrrrÚ__del__Ÿsþÿ"ÿz_ChannelReadyFuture.__del__r)rrrrr%r'r0r1r3r4r8r,r9r<r=r>rrrrr=s rcCst|ƒ}| ¡|Sr)rr=)r Zready_futurerrrÚchannel_ready_future¥sr?)Ú__doc__ÚcollectionsZloggingrr"r#rrZ getLoggerrr+r-Ú namedtuplerZServiceRpcHandlerr ZFuturerr?rrrrÚs$ ÿ öh