Struct Server 

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

Controller and completion future for a running server.

Clones can pause, resume, stop, or submit items to the server. Awaiting a Server resolves when the server has stopped. It always resolves to Ok(()).

Implementations

impl Server<Connection>

pub fn builder() -> ServerBuilder

Creates a network server builder with no application configuration.

impl<T> Server<T>

pub fn process(&self, item: T) -> Result<(), T>

Submits an item to the worker pool.

Returns the item unchanged if the server is paused or cannot accept it.

The server starts paused and resumes once the first worker is ready. It also pauses itself while no worker is available, so items submitted right after start or during worker restarts may be rejected.

pub fn pause(&self) -> impl Future<Output = ()> + use<T>

Pauses processing new items.

For network servers, listeners stop accepting connections, so new connections wait in the kernel listen backlog. Existing connections remain active.

pub fn resume(&self) -> impl Future<Output = ()> + use<T>

Resumes processing new items.

pub fn stop(&self, graceful: bool) -> impl Future<Output = ()> + use<T>

Stops processing new items and shuts down all workers.

If graceful is true, workers are given up to the graceful shutdown timeout to finish active work before they are stopped. A zero timeout makes the stop non-graceful.

The returned future resolves once the stop has completed. If the server has already stopped, it resolves immediately.

Trait Implementations

impl<T> Clone for Server<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Server<T>

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

Formats the value using the given formatter.

impl<T> Future for Server<T>

type Output = Result<(), Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.