Struct Request

pub struct Request { /* private fields */ }

Implementations

impl Request

pub fn new() -> Rc<Self>

pub fn create_with_rpc(rpc: Weak<dyn RpcProto>) -> Rc<Self>

pub fn cmd<'a>(self: &'a Rc<Self>, cmd: impl ToString) -> &'a Rc<Self>

pub fn msg<'a, T>(self: &'a Rc<Self>, msg: T) -> &'a Rc<Self>

where T: Serialize,

pub fn rsp<'a, F, P>(self: &'a Rc<Self>, cb: F) -> &'a Rc<Self>

where P: for<'de> Deserialize<'de>, F: Fn(P) + 'static,

pub fn finally<'a, F>(self: &'a Rc<Self>, finally: F) -> &'a Rc<Self>

where F: Fn(FinallyType) + 'static,

pub fn call(self: &Rc<Self>)

pub fn call_with_rpc(self: &Rc<Self>, rpc: Rc<dyn RpcProto>)

pub fn ping<'a>(self: &'a Rc<Self>) -> &'a Rc<Self>

pub fn timeout_ms<'a>(self: &'a Rc<Self>, timeout_ms: u32) -> &'a Rc<Self>

pub fn timeout<'a, F>(self: &'a Rc<Self>, timeout_cb: F) -> &'a Rc<Self>

where F: Fn() + 'static,

pub fn add_to<'a>(self: &'a Rc<Self>, dispose: &mut Dispose) -> &'a Rc<Self>

pub fn cancel<'a>(self: &'a Rc<Self>) -> &'a Rc<Self>

pub fn reset_cancel<'a>(self: &'a Rc<Self>) -> &'a Rc<Self>

pub fn retry<'a>(self: &'a Rc<Self>, count: i32) -> &'a Rc<Self>

pub fn disable_rsp<'a>(self: &'a Rc<Self>) -> &'a Rc<Self>

pub fn rpc<'a>(self: &'a Rc<Self>, rpc: Weak<dyn RpcProto>) -> &'a Rc<Self>

pub fn get_rpc(&self) -> Option<Weak<dyn RpcProto>>

pub fn is_canceled(&self) -> bool

pub fn canceled<'a>(self: &'a Rc<Self>, canceled: bool) -> &'a Rc<Self>

impl Request

pub async fn future<R>(self: &Rc<Self>) -> FutureRet<R>

where R: for<'de> Deserialize<'de> + 'static,