o û/‚i§ ã@sdZGdd„dƒZdS)z4Base class for bi-directional streaming RPC helpers.c@sJeZdZdZddd„Zdd„Zdd„Zd d „Zed d „ƒZ ed d„ƒZ dS)Ú BidiRpcBasea¤A base class for consuming a bi-directional streaming RPC. This maps gRPC's built-in interface which uses a request iterator and a response iterator into a socket-like :func:`send` and :func:`recv`. This is a more useful pattern for long-running or asymmetric streams (streams where there is not a direct correlation between the requests and responses). This does *not* retry the stream on errors. Args: start_rpc (Union[grpc.StreamStreamMultiCallable, grpc.aio.StreamStreamMultiCallable]): The gRPC method used to start the RPC. initial_request (Union[protobuf.Message, Callable[[], protobuf.Message]]): The initial request to yield. This is useful if an initial request is needed to start the stream. metadata (Sequence[Tuple(str, str)]): RPC metadata to include in the request. NcCs2||_||_||_| ¡|_d|_g|_d|_dS©N)Ú _start_rpcÚ_initial_requestÚ _rpc_metadataÚ _create_queueÚ_request_queueÚ_request_generatorÚ _callbacksÚcall)ÚselfÚ start_rpcÚinitial_requestÚmetadata©rúM/var/www/passon-env/lib/python3.10/site-packages/google/api_core/bidi_base.pyÚ__init__'s  zBidiRpcBase.__init__cCótdƒ‚)zCreate a queue for requests.z#`_create_queue` is not implemented.©ÚNotImplementedError©r rrrr0szBidiRpcBase._create_queuecCs|j |¡dS)aáAdds a callback that will be called when the RPC terminates. This occurs when the RPC errors or is successfully terminated. Args: callback (Union[Callable[[grpc.Future], None], Callable[[Any], None]]): The callback to execute after gRPC call completed (success or failure). For sync streaming gRPC: Callable[[grpc.Future], None] For async streaming gRPC: Callable[[Any], None] N)r Úappend)r ÚcallbackrrrÚadd_done_callback4szBidiRpcBase.add_done_callbackcCs|jD]}||ƒqdSr)r )r ÚfuturerrrrÚ _on_call_doneDs ÿzBidiRpcBase._on_call_donecCr)z&True if the gRPC call is not done yet.z`is_active` is not implemented.rrrrrÚ is_activePszBidiRpcBase.is_activecCs |j ¡S)z*Estimate of the number of queued requests.)rÚqsizerrrrÚpending_requestsUs zBidiRpcBase.pending_requests)NN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrrÚpropertyrrrrrrrs   rN)r!rrrrrÚs