B dE@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)selfchannelrE/var/www/html/venv/lib/python3.7/site-packages/grpc/beta/utilities.py__init__s  z_ChannelReadyFuture.__init__c Cs|dkr dn t|}|jfx^|jr2tq"|jrd|_|j|j|jt|j}d|_ndSWdQRXx|D]}t |t |qRWdS)NTF) r r r r rrrrr rrr)rr r!rrrcancelIs   z_ChannelReadyFuture.cancelc Cs|j|jSQRXdS)N)r r )rrrr cancelledZsz_ChannelReadyFuture.cancelledc Cs"|j|j o|j SQRXdS)N)r r r )rrrrrunning^sz_ChannelReadyFuture.runningc Cs|j|jp|jSQRXdS)N)r r r )rrrrdonebsz_ChannelReadyFuture.doneNcCs||dS)N)r)rrrrrresultfs z_ChannelReadyFuture.resultcCs||dS)N)r)rrrrr exceptionjs z_ChannelReadyFuture.exceptioncCs||dS)N)r)rrrrr tracebackns z_ChannelReadyFuture.tracebackc Cs:|j"|js$|js$|j|dSWdQRX||dS)N)r r r r append)rfnrrradd_done_callbackrs   z%_ChannelReadyFuture.add_done_callbackc Cs(|j|jj|jddWdQRXdS)NT)Ztry_to_connect)r r subscriber)rrrrstartzsz_ChannelReadyFuture.startc Cs0|j |js"|js"|j|jWdQRXdS)N)r r r r rr)rrrr__del__~s z_ChannelReadyFuture.__del__)N)N)N)__name__ __module__ __qualname__rrrr"r#r$r%r&r'r(r+r-r.rrrrrs   rcCst|}||S)aCreates 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. )rr-)rZ ready_futurerrrchannel_ready_futuresr2) __doc__rrZ grpc.betarrZgrpc.framework.foundationrrrFuturerr2rrrrs    g