Struct ReplyContext

pub struct ReplyContext<T, E>(/* private fields */);

Object used to reply to requests passed to the server.

Implementations

impl<T, E> ReplyContext<T, E>

pub fn reply(self, data: T) -> Result<(), Error<E>>

Send a reply back to originating client.

Example

use std::thread;
use ump_ng::{channel, MsgType};

let (server, client) = channel::<(), String, String, ()>();
let server_thread = thread::spawn(move || {
  let MsgType::Request(data, rctx) = server.wait().unwrap() else {
    panic!("Not Request type");
  };
  let reply = format!("Hello, {}!", data);
  rctx.reply(reply).unwrap();
});
let msg = String::from("Client");
let reply = client.req(msg).unwrap();
assert_eq!(reply, "Hello, Client!");
server_thread.join().unwrap();

Errors

If the originating caller is no longer waiting for a reply (i.e. was dropped) Error::OriginDisappeared is returned.

Semantics

This call is safe to make after the server context has been released.

pub fn fail(self, err: E) -> Result<(), Error<E>>

Return an error to originating client. This will cause the calling client to return an error. The error passed in the err parameter will be wrapped in a Error::App(err).

Example

use std::thread;
use ump_ng::{channel, Error, MsgType};

#[derive(Debug, PartialEq)]
enum MyError {
  SomeError(String)
}

let (server, client) = channel::<String, String, String, MyError>();
let server_thread = thread::spawn(move || {
  let MsgType::Request(_, rctx) = server.wait().unwrap() else {
    panic!("Unexpected message type");
  };
  rctx.fail(MyError::SomeError("failed".to_string())).unwrap();
});
let msg = String::from("Client");
let reply = client.req(msg);
match reply {
  Err(Error::App(MyError::SomeError(s))) => {
    assert_eq!(s, "failed");
  }
  _ => {
    panic!("Unexpected return value");
  }
}
server_thread.join().unwrap();

Errors

Error::OriginDisappeared indicates that the originating caller is no longer waiting for a reply (i.e. it was dropped).

Semantics

This call is safe to make after the server context has been released.

Trait Implementations

impl<T, E> TryFrom<SetCtx<T, RCtxState, E>> for ReplyContext<T, E>

fn try_from( sctx: SetCtx<T, RCtxState, E>, ) -> Result<ReplyContext<T, E>, <ReplyContext<T, E> as TryFrom<SetCtx<T, RCtxState, E>>>::Error>

Convert a SetCtx into a ReplyContext.

Sets the SetCtx’s stat to Active.

type Error = Error<E>

The type returned in the event of a conversion error.