Struct UDSMsgServer

pub struct UDSMsgServer<T> {
    pub path_name: String,
    pub name: String,
    pub connections: Arc<Mutex<HashMap<String, Sender<Option<T>>>>>,
}

Fields

path_name: String

name: String

connections: Arc<Mutex<HashMap<String, Sender<Option<T>>>>>

Implementations

impl<T> UDSMsgServer<T>

where T: DeserializeOwned + Serialize + Send + 'static + Clone,

pub fn new(path_name: &str, server_name: &str) -> UDSMsgServer<T>

addr is socket address. like: 127.0.0.1:6666. name is the server’s name, to identity which server it is.

pub fn start_server<F>( &self, first_msg: T, process_function: F, ) -> Box<dyn Future<Item = (), Error = ()> + Send + 'static>

where F: FnMut(String, T) -> Vec<(String, T)> + Send + Sync + 'static + Clone,

first_msg is the first message that server send to the client which just connect to server. process_fuction receive a tuple of <client_name, message>, and return a series of tuple of (client_name,message) indicating which message will be sent to which client. Note that if you want to send a message to current client, you should set client_name as a string with 0 length, i.e. “”

Trait Implementations

impl<T: Debug> Debug for UDSMsgServer<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.