o Zh@sfdZddlZddlZddlmZddlmZddlmZddlmZdZ Gdd d ej Z d d Z dS) z'Utilities for the gRPC Python Beta API.N)implementations) interfaces) callable_util)futurez6Exception calling connectivity future "done" callback!c@szeZdZddZddZddZddZd d Zd d Zd dZ dddZ dddZ dddZ ddZ ddZddZdS)_ChannelReadyFuturecCs&t|_||_d|_d|_g|_dS)NF) threading Condition _condition_channel_matured _cancelled_done_callbacks)selfchannelrJ/var/www/html/lang_env/lib/python3.10/site-packages/grpc/beta/utilities.py__init__s  z_ChannelReadyFuture.__init__cCs|durdnt|}|j5 |jrt|jr$ WddS|dur.|jn|t}|dkr|j|jj|jddWddS1swYdS)NT)Ztry_to_connect)r r subscriberr$rrrstart~s"z_ChannelReadyFuture.startcCsf|j&|js|js!|j|jWddSWddSWddS1s,wYdSr#)r r r r rrr$rrr__del__s "z_ChannelReadyFuture.__del__r#)__name__ __module__ __qualname__rrrr"r%r'r(r,r.r/r2r4r5rrrrrs    rcCst|}||S)a&Creates a future.Future tracking when an implementations.Channel is ready. Cancelling the returned future.Future does not tell the given implementations.Channel to abandon attempts it may have been making to connect; cancelling merely deactivates the return future.Future's subscription to the given implementations.Channel's connectivity. Args: channel: An implementations.Channel. Returns: A future.Future that matures when the given Channel has connectivity interfaces.ChannelConnectivity.READY. )rr4)rZ ready_futurerrrchannel_ready_futuresr9) __doc__rrZ grpc.betarrZgrpc.framework.foundationrrrFuturerr9rrrrs      j