Struct quic_rpc::client::RpcClient

pub struct RpcClient<S: Service, C: ChannelTypes> { /* private fields */ }

A client for a specific service

This is a wrapper around a crate::Channel that serves as the entry point for the client DSL. S is the service type, C is the channel type.

Implementations

impl<S: Service, C: ChannelTypes> RpcClient<S, C>

pub fn new(channel: C::Channel<S::Res, S::Req>) -> Self

Create a new client channel from a channel and a service type

pub async fn rpc<M>(&self, msg: M) -> Result<M::Response, RpcClientError<C>>where
    M: Msg<S, Pattern = Rpc> + Into<S::Req>,

RPC call to the server, single request, single response

pub async fn server_streaming<M>(
    &self,
    msg: M
) -> Result<BoxStream<'static, Result<M::Response, StreamingResponseItemError<C>>>, StreamingResponseError<C>>where
    M: Msg<S, Pattern = ServerStreaming> + Into<S::Req>,

Bidi call to the server, request opens a stream, response is a stream

pub async fn client_streaming<M>(
    &self,
    msg: M
) -> Result<(UpdateSink<S, C, M>, BoxFuture<'static, Result<M::Response, ClientStreamingItemError<C>>>), ClientStreamingError<C>>where
    M: Msg<S, Pattern = ClientStreaming> + Into<S::Req>,

Call to the server that allows the client to stream, single response

pub async fn bidi<M>(
    &self,
    msg: M
) -> Result<(UpdateSink<S, C, M>, BoxStream<'static, Result<M::Response, BidiItemError<C>>>), BidiError<C>>where
    M: Msg<S, Pattern = BidiStreaming> + Into<S::Req>,

Bidi call to the server, request opens a stream, response is a stream

Trait Implementations

impl<S: Service, C: ChannelTypes> Clone for RpcClient<S, C>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug + Service, C: Debug + ChannelTypes> Debug for RpcClient<S, C>where
    C::Channel<S::Res, S::Req>: Debug,
    S::Res: Debug,
    S::Req: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.