Struct InFlightRequest 

pub struct InFlightRequest<Req, Res> { /* private fields */ }

A request produced by Channel::requests.

If dropped without calling execute, a cancellation message will be sent to the Channel to clean up associated request state.

Implementations

impl<Req, Res> InFlightRequest<Req, Res>

pub fn get(&self) -> &Request<Req>

Returns a reference to the request.

pub async fn execute<S>(self, serve: S)

where Req: RequestName, S: Serve<Req = 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:

1. The channel that yielded this request receives a cancellation message for this request.
2. The request deadline is reached.
3. The service function completes.

If the returned Future is dropped before completion, a cancellation message will be sent to the Channel to clean up associated request state.

Example

use tarpc::{
    context,
    client::{self, NewClient},
    server::{self, BaseChannel, Channel, serve},
    transport,
};
use futures::prelude::*;

#[tokio::main]
async fn main() {
    let (tx, rx) = transport::channel::unbounded();
    let server = BaseChannel::new(server::Config::default(), rx);
    let NewClient { client, dispatch } = client::new(client::Config::default(), tx);
    tokio::spawn(dispatch);

    tokio::spawn(async move {
        let mut requests = server.requests();
        while let Some(Ok(in_flight_request)) = requests.next().await {
            in_flight_request.execute(serve(|_, i| async move { Ok(i + 1) })).await;
        }

    });
    assert_eq!(client.call(context::current(), 1).await.unwrap(), 2);
}

Trait Implementations

impl<Req, Res> Debug for InFlightRequest<Req, Res>

where Req: Debug, Res: Debug,

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

Formats the value using the given formatter.