Struct WsSessionFactory 

pub struct WsSessionFactory<O, S, F, E>
where
    O: Into<Option<WsMessage>> + Unpin + 'static,
    S: MutService<Input = WsSessionEvent, Output = O> + Unpin + 'static,
    F: Fn(&HttpRequest) -> Result<S, Error> + 'static,
    E: Fn(&mut S, S::Error) -> Result<(), S::Error> + Unpin + 'static,
{ /* private fields */ }

The entry point to this module. It is used to create session services as connections are established by client, and acts as a actix_web Handler.

See the this module’s documentation for details and examples.

Implementations

impl<O, S, F, E> WsSessionFactory<O, S, F, E>

where O: Into<Option<WsMessage>> + Unpin + 'static, S: MutService<Input = WsSessionEvent, Output = O> + Unpin + 'static, F: Fn(&HttpRequest) -> Result<S, Error> + 'static, E: Fn(&mut S, S::Error) -> Result<(), S::Error> + Unpin + 'static,

pub fn new(factory: F, error_handler: E) -> Self

Encapsulate the given sod::Service or sod::MutService factory and error handler, making the service factory compatible with a native actix_web::Handler and underlying session services compabile with a native actix::Handler and actix::StreamHandler.

Trait Implementations

impl<O, S, F, E> Clone for WsSessionFactory<O, S, F, E>

where O: Into<Option<WsMessage>> + Unpin + 'static, S: MutService<Input = WsSessionEvent, Output = O> + Unpin + 'static, F: Fn(&HttpRequest) -> Result<S, Error> + 'static, E: Fn(&mut S, S::Error) -> Result<(), S::Error> + Unpin + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<O, S, F, E> Handler<(HttpRequest, Payload)> for WsSessionFactory<O, S, F, E>

where O: Into<Option<WsMessage>> + Unpin + 'static, S: MutService<Input = WsSessionEvent, Output = O> + Unpin + 'static, F: Fn(&HttpRequest) -> Result<S, Error> + 'static, E: Fn(&mut S, S::Error) -> Result<(), S::Error> + Unpin + 'static,

type Output = Result<HttpResponse, Error>

type Future = SettableFuture<Result<HttpResponse, Error>>

fn call(&self, (req, stream): (HttpRequest, Payload)) -> Self::Future