Struct tarpc::server::InFlightRequest
source · [−]pub struct InFlightRequest<Req, Res> { /* private fields */ }
Expand description
A request produced by Channel::requests.
Implementations
sourceimpl<Req, Res> InFlightRequest<Req, Res>
impl<Req, Res> InFlightRequest<Req, Res>
sourcepub async fn execute<S>(self, serve: S) where
S: Serve<Req, Resp = Res>,
pub async fn execute<S>(self, serve: S) where
S: Serve<Req, Resp = Res>,
Returns a future that executes the request using the given service function. The service function’s output is automatically sent back to the Channel that yielded this request. The request will be executed in the scope of this request’s context.
The returned future will stop executing when the first of the following conditions is met:
- The channel that yielded this request receives a cancellation message for this request.
- The request deadline is reached.
- The service function completes.
Trait Implementations
Auto Trait Implementations
impl<Req, Res> !RefUnwindSafe for InFlightRequest<Req, Res>
impl<Req, Res> Send for InFlightRequest<Req, Res> where
Req: Send,
Res: Send,
impl<Req, Res> Sync for InFlightRequest<Req, Res> where
Req: Sync,
Res: Send,
impl<Req, Res> Unpin for InFlightRequest<Req, Res> where
Req: Unpin,
impl<Req, Res> !UnwindSafe for InFlightRequest<Req, Res>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more