Struct Server 

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

Server controller

Implementations

impl<T> Server<T>

pub fn build() -> ServerBuilder

Start streaming server building process

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

Send item to worker pool

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

Pause accepting incoming connections

If socket contains some pending connection, they might be dropped. All opened connection remains active.

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

Resume accepting incoming connections

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

Stop incoming connection processing, stop all workers and exit.

If server starts with spawn() method, then spawned thread get terminated.

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.