Struct Client 

pub struct Client<T> { /* private fields */ }

Implementations

impl<T: RpcTransport> Client<T>

pub fn new(transport: T, implemented: impl IntoIterator<Item = String>) -> Self

implemented is the authenticated endpoint’s advertised handler set, not ALL_METHODS or the proto’s maturity declarations.

pub async fn call<M: UnaryRpc>( &self, request: &M::Request, ) -> Result<M::Response, ClientError<T::Error>>

pub async fn observe<M: ServerStreamingRpc>( &self, request: &M::Request, ) -> Result<Messages<T::Reader, M::Response>, ClientError<T::Error>>

pub async fn exchange<M: BidirectionalRpc>( &self, opening: &M::Request, ) -> Result<(Sender<T::Writer, M::Request>, Messages<T::Reader, M::Response>), ClientError<T::Error>>

Returns independently borrowable halves so receives cannot block sends.