Struct Request 

pub struct Request<Send, Recv> { /* private fields */ }

If you need synchronous RPC, you can use this utility

use lifeline::request::Request;

struct Send(usize);
#[derive(Debug, Eq, PartialEq)]
struct Recv(usize);

lifeline::test::block_on(async {
  let (request, mut recv) = Request::send(Send(42));

  // send the request along a channel, and in a service:
  request.reply(|send| async move { Recv(send.0) }).await;

  let resp = recv.await;
  assert_eq!(Ok(Recv(42)), resp);
})

Implementations

impl<Send, Recv> Request<Send, Recv>

pub fn send(send: Send) -> (Self, Receiver<Recv>)

Constructs a pair of Request, and Receiver for the response

pub async fn reply<Fn, Fut>(self, respond: Fn) -> Result<(), Recv>

where Fn: FnOnce(Send) -> Fut, Fut: Future<Output = Recv>,

Asynchronously replies to the given request, using the provided closure