Struct tk_http::server::buffered::WebsocketService

pub struct WebsocketService<H, I, T, U> { /* fields omitted */ }

An instance of websocket factory, created by WebsocketFactory itself

Trait Implementations

impl<S, H, I, T, U> Service<S> for WebsocketService<H, I, T, U> where
    H: Fn(Request, Encoder<S>) -> T,
    I: Fn(WriteFramed<S, WebsocketCodec>, ReadFramed<S, WebsocketCodec>) -> U,
    T: Future<Item = EncoderDone<S>, Error = Error>,
    U: Future<Item = (), Error = ()> + 'static, 

type Future = T

A future returned by call()

type WebsocketFuture = U

A future returned by start_websocket, it's spawned on the main loop hence needed to be static.

fn call(&mut self, request: Request, encoder: Encoder<S>) -> T

A method which is called when request arrives, including the websocket negotiation request.

fn start_websocket(
    &mut self,
    output: WriteFramed<S, WebsocketCodec>,
    input: ReadFramed<S, WebsocketCodec>
) -> U

A method which is called when websocket connection established