Trait mz_service::grpc::BidiProtoClient
source · pub trait BidiProtoClient: Debug + Send {
type PC: Debug + Send + Sync + 'static;
type PR: Debug + Send + Sync + 'static;
fn new(inner: ClientTransport) -> Self
where
Self: Sized;
fn establish_bidi_stream<'life0, 'async_trait>(
&'life0 mut self,
rx: UnboundedReceiverStream<Self::PC>
) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<Self::PR>>, Status>> + Send + 'async_trait>>
where
Self: 'async_trait,
'life0: 'async_trait;
}
Expand description
Encapsulates the core functionality of a tonic gRPC client for a service that exposes a single bidirectional RPC stream.
See the documentation on GrpcClient
for details.