pub struct WrpcClient { /* private fields */ }Trait Implementations§
source§impl Clone for WrpcClient
impl Clone for WrpcClient
source§fn clone(&self) -> WrpcClient
fn clone(&self) -> WrpcClient
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl Invoke for WrpcClient
impl Invoke for WrpcClient
source§impl Serve for WrpcClient
impl Serve for WrpcClient
Auto Trait Implementations§
impl Freeze for WrpcClient
impl !RefUnwindSafe for WrpcClient
impl Send for WrpcClient
impl Sync for WrpcClient
impl Unpin for WrpcClient
impl !UnwindSafe for WrpcClient
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit)source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Requestsource§impl<T> InvokeExt for Twhere
T: Invoke,
impl<T> InvokeExt for Twhere
T: Invoke,
source§fn invoke_values<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<(Results, Option<impl Future<Output = Result<(), Error>> + Send + 'static>), Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
fn invoke_values<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<(Results, Option<impl Future<Output = Result<(), Error>> + Send + 'static>), Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
Invoke function
func on instance instance using typed Params and Resultssource§fn invoke_values_blocking<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<Results, Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
fn invoke_values_blocking<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<Results, Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
Invoke function
func on instance instance using typed Params and Results
This is like Self::invoke_values, but it only results once all I/O is donesource§fn timeout(&self, timeout: Duration) -> Timeout<'_, Self>
fn timeout(&self, timeout: Duration) -> Timeout<'_, Self>
Returns a
Timeout, wrapping Self with an implementation of Invoke, which will
error, if call to Invoke::invoke does not return within a supplied timeoutsource§fn timeout_owned(self, timeout: Duration) -> TimeoutOwned<Self>where
Self: Sized,
fn timeout_owned(self, timeout: Duration) -> TimeoutOwned<Self>where
Self: Sized,
source§impl<T> ServeExt for Twhere
T: Serve,
impl<T> ServeExt for Twhere
T: Serve,
source§fn serve_values<Params, Results>(
&self,
instance: &str,
func: &str,
paths: impl Into<Arc<[Box<[Option<usize>]>]>> + Send,
) -> impl Future<Output = Result<impl Stream<Item = Result<(Self::Context, Params, Option<impl Future<Output = Result<(), Error>> + Send + Unpin + 'static>, impl FnOnce(Results) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>> + Send + 'static), Error>> + Send + 'static, Error>> + Sendwhere
Params: TupleDecode<Self::Incoming> + Send + 'static,
Results: TupleEncode<Self::Outgoing> + Send + 'static,
<<Params as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
<<Results as Encode<Self::Outgoing>>::Encoder as Encoder<Results>>::Error: Error + Send + Sync + 'static,
fn serve_values<Params, Results>(
&self,
instance: &str,
func: &str,
paths: impl Into<Arc<[Box<[Option<usize>]>]>> + Send,
) -> impl Future<Output = Result<impl Stream<Item = Result<(Self::Context, Params, Option<impl Future<Output = Result<(), Error>> + Send + Unpin + 'static>, impl FnOnce(Results) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>> + Send + 'static), Error>> + Send + 'static, Error>> + Sendwhere
Params: TupleDecode<Self::Incoming> + Send + 'static,
Results: TupleEncode<Self::Outgoing> + Send + 'static,
<<Params as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
<<Results as Encode<Self::Outgoing>>::Encoder as Encoder<Results>>::Error: Error + Send + Sync + 'static,
Serve function
func from instance instance using typed Params and Results