Struct rpc_core::rpc::Rpc

pub struct Rpc { /* private fields */ }

Implementations

impl Rpc

pub fn new(connection: Option<Rc<RefCell<dyn Connection>>>) -> Rc<Rpc>

pub fn subscribe<C, F, P, R>(&self, cmd: C, handle: F)

where C: ToString, P: for<'de> Deserialize<'de>, R: Serialize, F: Fn(P) -> R + 'static,

pub fn unsubscribe<C>(&self, cmd: C)

where C: ToString,

pub fn create_request(&self) -> Rc<Request>

pub fn cmd<T>(&self, cmd: T) -> Rc<Request>

where T: ToString,

pub fn ping(&self) -> Rc<Request>

pub fn ping_msg(&self, payload: impl ToString) -> Rc<Request>

pub fn set_timer<F>(&self, timer_impl: F)

where F: Fn(u32, Box<dyn Fn()>) + 'static,

pub fn set_ready(&self, ready: bool)

pub fn get_connection(&self) -> Rc<RefCell<dyn Connection>>

Trait Implementations

impl RpcProto for Rpc

fn make_seq(&self) -> SeqType

fn send_request(&self, request: &Request)

fn is_ready(&self) -> bool