Struct Server

pub struct Server<H>
where
    H: RequestHandler + Sync + Send + 'static,
{ /* private fields */ }

The server manages client connections, verifies message formats, and handles sending and receiving messages.

Type Parameters

• H: Type that implements the RequestHandler trait for handling incoming requests.

Fields

• address: The socket address on which the server is listening.
• handles: Vector of join handles for spawned connection tasks.
• send_all_tx: Sender channel for broadcasting messages to all clients.
• cmd_rx: Receiver channel for receiving commands from clients.
• cmd_tx: Sender channel for sending commands to clients.
• message_handler: Shared handler function to handle all incoming messages.

Implementations

impl<H> Server<H>

where H: RequestHandler + Sync + Send,

pub fn get_addr(&self) -> SocketAddr

Gets the socket address of the server.

Returns

The socket address on which the server is listening.

pub fn add_conn(&mut self, conn_stream: TcpStream)

Adds a new connection to the server.

Arguments

• conn_stream - The TCP stream representing the connection to the client.

pub fn send_all(&self, message: String)

Sends a message to all connected clients.

Arguments

• message - The message to be sent to all clients.

pub async fn listen(&mut self)

Starts listening for incoming connections and commands.

Examples found in repository

examples/chat_room_server.rs (line 52)

async fn main() {
    // Getting a socket addr obj
    let addr: SocketAddr = "127.0.0.1:5555".parse().expect("Could not parse ip addr");

    // Creating instance of a handler
    let handler = ChatRoomHandler::new();

    // Creating a server obj
    let mut server = Server::new(addr, handler);

    // Start server listener
    server.listen().await;
}

pub fn new(address: SocketAddr, message_handler: H) -> Self

Creates a new instance of Server.

Arguments

• address - The socket address on which the server will listen for incoming connections.
• message_handler - The handler for processing incoming requests.

Returns

A new instance of Server.

Examples found in repository

examples/chat_room_server.rs (line 49)

async fn main() {
    // Getting a socket addr obj
    let addr: SocketAddr = "127.0.0.1:5555".parse().expect("Could not parse ip addr");

    // Creating instance of a handler
    let handler = ChatRoomHandler::new();

    // Creating a server obj
    let mut server = Server::new(addr, handler);

    // Start server listener
    server.listen().await;
}