pub struct Client { /* private fields */ }Implementations§
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Client
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl !UnwindSafe for Client
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> 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> 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