Struct Server

pub struct Server<S, M> { /* private fields */ }

Represents our server.

Implementations

impl<S, M> Server<S, M>

where S: Default, M: Serialize + DeserializeOwned,

pub fn bind(addr: &str) -> Result<Self, Box<dyn Error>>

Create a new server by binding to a listening TCP port.

pub fn on_closed(self, cb: fn(&mut Conn<S, M>)) -> Self

Setup a callback for closed connections.

This callback will only ever be run, when the client terminates the connection to the server.

pub fn on_closed_unexpected(self, cb: fn(&mut Conn<S, M>)) -> Self

Setup a callback for unexpectedly closed connections.

This callback will be run when the connection is closed by the client when the server is receiving a message.

pub fn on_connection(self, cb: fn(&mut Conn<S, M>)) -> Self

Setup a callback for each new connection.

This callback will be run when the server stablishes a new connection with a client, before any messages are recevied.

pub fn on_error(self, cb: fn(&mut Conn<S, M>, Box<dyn Error>)) -> Self

Setup a callback for connection errors.

This callback will be run whenever there is an error attempting to get the next message from a connection, e.g. a bad message that fails to be deserialized.

pub fn on_message(self, cb: fn(&mut Conn<S, M>, M)) -> Self

Setup a calback for each received message.

This is the main callbcak, which is run every time a connection sends a new message.

pub fn run(self) -> !

Run the server by using the given callback function on connections.

At this moment, the server starts adding inbound connections and handling them, by using the callbacks given during its creation.