smallnest / rpcx-rs Goto Github PK

    pub fn call<T>(
        &mut self,
        service_path: &str,
        service_method: &str,
        is_oneway: bool,
        metadata: &Metadata,
        args: &dyn RpcxParam,
    ) -> Option<Result<T>>
    where
        T: RpcxParam + Default,
    {
        let rt = Runtime::new().unwrap();
        ...

    register_func!(
        rpc_server,
        RPC_PS_Path,
        RPC_PS_Write,
        write,
        "".to_owned(),
        WriteRequest,
        WriteResponse
    );

struct AAA{
}

impl AAA{
    pub fn write(req) -> rep {}
}


 register_func!(
        rpc_server,
        RPC_PS_Path,
        RPC_PS_Write,
        AAA.write,
        "".to_owned(),
        WriteRequest,
        WriteResponse
    );

let write = |x: WriteRequest| -> WriteResponse {
        let rep: WriteResponse = Default::default();
        rep
    };

 register_func!(
        rpc_server,
        RPC_PS_Path,
        RPC_PS_Write,
        write,
        "".to_owned(),
        WriteRequest,
        WriteResponse
    );