Struct Server

Source

pub struct Server<T: XvcServer> { /* private fields */ }

Implementations§

Source §

impl<T: XvcServer> Server<T>

Source

pub fn new(server: T, config: Config) -> Server<T>

Create a new server wrapping server with the given config.

Examples found in repository ?

examples/mock_server.rs (line 43)

42async fn main() -> Result<(), Box<dyn std::error::Error>> {
43    let server = Server::new(Loopback, Config::default());
44    let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 2542);
45    println!("XVC loopback server listening on {addr}");
46    server.listen(addr).await?;
47    Ok(())
48}

Source

pub async fn listen(&self, addr: impl ToSocketAddrs) -> Result<()>
where T: Send + 'static,

Bind to addr and serve clients until the process exits.

This is the standard production entry point. To shut the server down programmatically (e.g. in tests), use listen_on with a CancellationToken.

Examples found in repository ?

examples/mock_server.rs (line 46)

42async fn main() -> Result<(), Box<dyn std::error::Error>> {
43    let server = Server::new(Loopback, Config::default());
44    let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 2542);
45    println!("XVC loopback server listening on {addr}");
46    server.listen(addr).await?;
47    Ok(())
48}

Source

pub async fn listen_on( &self, listener: TcpListener, shutdown: CancellationToken, ) -> Result<()>
where T: Send + 'static,

Serve clients from a pre-bound listener until shutdown is cancelled.

When shutdown is cancelled the accept loop exits cleanly; any connection that is already being served runs to completion before the task finishes.

This entry point is useful when the caller needs to control the server lifetime programmatically — for example in tests, or to hook into a process-wide signal handler:

let listener = tokio::net::TcpListener::bind("127.0.0.1:0").await?;
let addr = listener.local_addr()?;
let token = CancellationToken::new();

// Shut down on Ctrl+C
tokio::spawn({
    let token = token.clone();
    async move {
        tokio::signal::ctrl_c().await.unwrap();
        token.cancel();
    }
});

server.listen_on(listener, token).await?;