Struct Server 

pub struct Server<T>(pub Arc<Mutex<InnerServer<T>>>);

Tuple Fields

0: Arc<Mutex<InnerServer<T>>>

Implementations

impl<T: KnetTransform + Send + Debug + Sync + Clone + 'static> Server<T>

pub async fn run( addr: impl ToSocketAddrs + Sync + Send, ) -> Result<(Self, UnboundedReceiver<Event<T>>), Box<dyn Error + Send + Sync>>

Run the server on the addr adress and return and the server and Receiver

pub async fn write_all( server: Arc<Mutex<InnerServer<T>>>, data: T, ) -> Result<(), Box<dyn Error + Send + Sync>>

Write the data to all connection accept by the server

pub async fn write( server: Arc<Mutex<InnerServer<T>>>, data: T, id: Id, ) -> Result<(), Box<dyn Error + Send + Sync>>

Write the data to a specify connection