Struct ServerHandle 

pub struct ServerHandle { /* private fields */ }

A cloneable handle to a running server, safe to use from any thread.

let server = net_io::serve("127.0.0.1:7000", |conn| { conn.send_all(b"hi\n")?; Ok(()) })?;
let handle = server.handle();
std::thread::spawn(move || {
    // ... wait for a signal from the application's signal library ...
    handle.request_stop();
});
let report = server.wait_for_stop();
println!("drained: {} graceful, {} killed in {:?}", report.graceful, report.killed, report.took);

Implementations

impl ServerHandle

pub fn kill(&self, id: ConnectionId, reason: KillReason) -> bool

Aborts the connection id; false if it already closed or belongs to another server.

pub fn close_door(&self)

Stops accepting.

pub fn request_stop(&self)

Makes Server::wait_for_stop return after the drain. Does not block.

pub fn wake_all(&self)

Interrupts every worker’s and acceptor’s wait so a control-line change is seen at once.

pub fn completer(&self, worker: WorkerId) -> Option<Completer>

The completion queue of worker.

pub fn stats(&self) -> Stats

Counters summed over the workers.

pub fn door(&self) -> DoorState

Whether the server is accepting.

Trait Implementations

impl Clone for ServerHandle

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ServerHandle

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

Formats the value using the given formatter.