Struct spirit_tokio::handlers::PerConnection

pub struct PerConnection<F>(pub F);

A Transformation that creates a new future from each accepted connection.

For each connection yielded from the acceptor (passed in as the input resource), the function is used to create a new future. That new future is spawned into tokio runtime. Note that even when this resource gets uninstalled, the spawned futures from the connections are left running.

In case the acceptor yields an error, it is dropped and not used any more. Note that some primitives, like TcpListenWithLimits handles errors internally and never returns any, therefore it might be a good candidate for long-running servers.

Examples

Trait Implementations

impl<F, Fut, A, II, SF> Transformation<A, II, SF> for PerConnection<F> where
    A: Accept,
    F: Clone + FnMut(A::Connection, &SF) -> Fut + 'static,
    Fut: Future<Output = ()> + 'static,
    SF: Clone + 'static, 

type OutputResource = Acceptor<A, F, SF>

The type of resource after the transformation.

type OutputInstaller = FutureInstaller

The type of installer after the transformation.

fn installer(&mut self, _: II, _: &str) -> FutureInstaller

Creates the installer.

fn transform(
    &mut self,
    accept: A,
    cfg: &SF,
    name: &'static str
) -> Result<Acceptor<A, F, SF>, AnyError>

Transforms one instance of the resource.