Struct Server 

pub struct Server {
    pub handles: SyncHashMap<String, Box<dyn Stub>>,
    pub codec: Codecs,
    pub stub: ServerStub,
}

Fields

handles: SyncHashMap<String, Box<dyn Stub>>

codec: Codecs

stub: ServerStub

Implementations

impl Server

pub fn call(&self, stream: TcpStream)

impl Server

pub fn register<H>(&mut self, name: &str, handle: H)

where H: Stub + 'static,

register a handle to server

use mco_rpc::server::{Handler};

pub struct H{}

impl Handler for H{
    type Req = i32;
    type Resp = i32;

    fn handle(&self, req: Self::Req) -> mco::std::errors::Result<Self::Resp> {
        return Ok(req);
    }
}

pub fn register_fn<Req: DeserializeOwned + 'static, Resp: Serialize + 'static, F>( &mut self, name: &str, f: F, )

where F: Fn(Req) -> Result<Resp> + 'static,

register a func into server for example:

use mco_rpc::server::{Server};
let mut s = Server::default();
fn handle(req: i32) -> mco::std::errors::Result<i32> {
    return Ok(req + 1);
}
    //s.codec = Codecs::JsonCodec(JsonCodec{});
    s.register_fn("handle", handle);
    s.register_fn("handle_fn2", |arg:i32| -> mco::std::errors::Result<i32>{
        Ok(1)
    });

pub fn serve<A>(self, addr: A)

where A: ToSocketAddrs,

Trait Implementations

impl Default for Server

fn default() -> Self

Returns the “default value” for a type.